diff --git a/pom.xml b/pom.xml
index ec9989e5..2de100d1 100644
--- a/pom.xml
+++ b/pom.xml
@@ -43,7 +43,7 @@
     <dependency>
       <groupId>com.google.cloud</groupId>
       <artifactId>google-cloud-pubsublite</artifactId>
-      <version>0.15.0</version>
+      <version>0.16.0</version>
     </dependency>
     <dependency>
       <groupId>com.google.api.grpc</groupId>
diff --git a/samples/snapshot/pom.xml b/samples/snapshot/pom.xml
index b6684b04..20ade6e2 100644
--- a/samples/snapshot/pom.xml
+++ b/samples/snapshot/pom.xml
@@ -44,7 +44,7 @@
     <dependency>
       <groupId>com.google.cloud</groupId>
       <artifactId>google-cloud-pubsublite</artifactId>
-      <version>0.14.2</version>
+      <version>0.16.0</version>
     </dependency>
     <dependency>
       <groupId>junit</groupId>
diff --git a/samples/snippets/pom.xml b/samples/snippets/pom.xml
index 12b8a0a7..a7e88b6a 100644
--- a/samples/snippets/pom.xml
+++ b/samples/snippets/pom.xml
@@ -44,7 +44,7 @@
     <dependency>
       <groupId>com.google.cloud</groupId>
       <artifactId>google-cloud-pubsublite</artifactId>
-      <version>0.14.2</version>
+      <version>0.16.0</version>
     </dependency>
     <dependency>
       <groupId>junit</groupId>
diff --git a/src/main/java/com/google/cloud/pubsublite/spark/internal/PartitionSubscriberFactory.java b/src/main/java/com/google/cloud/pubsublite/spark/internal/PartitionSubscriberFactory.java
index 8ef57d3b..61798422 100644
--- a/src/main/java/com/google/cloud/pubsublite/spark/internal/PartitionSubscriberFactory.java
+++ b/src/main/java/com/google/cloud/pubsublite/spark/internal/PartitionSubscriberFactory.java
@@ -21,14 +21,12 @@
 import com.google.cloud.pubsublite.Partition;
 import com.google.cloud.pubsublite.SequencedMessage;
 import com.google.cloud.pubsublite.internal.wire.Subscriber;
-import com.google.common.collect.ImmutableList;
 import java.io.Serializable;
+import java.util.List;
 import java.util.function.Consumer;
 
 public interface PartitionSubscriberFactory extends Serializable {
   Subscriber newSubscriber(
-      Partition partition,
-      Offset offset,
-      Consumer<ImmutableList<SequencedMessage>> message_consumer)
+      Partition partition, Offset offset, Consumer<List<SequencedMessage>> message_consumer)
       throws ApiException;
 }