From 7e7fccf198fca72bde6ffd1966758903feec148f Mon Sep 17 00:00:00 2001
From: Michael Jiang <jiangmichael@google.com>
Date: Wed, 16 Jun 2021 16:50:44 -0400
Subject: [PATCH 1/2] update

---
 pom.xml                                                       | 2 +-
 samples/snapshot/pom.xml                                      | 2 +-
 samples/snippets/pom.xml                                      | 2 +-
 .../pubsublite/spark/internal/PartitionSubscriberFactory.java | 4 ++--
 4 files changed, 5 insertions(+), 5 deletions(-)

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..5cebc575 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,14 @@
 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)
+      Consumer<List<SequencedMessage>> message_consumer)
       throws ApiException;
 }

From 1d20c73b0fe6ebf5c4f99f7e1e4937c98c9143cf Mon Sep 17 00:00:00 2001
From: Michael Jiang <jiangmichael@google.com>
Date: Wed, 16 Jun 2021 16:58:53 -0400
Subject: [PATCH 2/2] update

---
 .../pubsublite/spark/internal/PartitionSubscriberFactory.java | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

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 5cebc575..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
@@ -27,8 +27,6 @@
 
 public interface PartitionSubscriberFactory extends Serializable {
   Subscriber newSubscriber(
-      Partition partition,
-      Offset offset,
-      Consumer<List<SequencedMessage>> message_consumer)
+      Partition partition, Offset offset, Consumer<List<SequencedMessage>> message_consumer)
       throws ApiException;
 }