From 66e879e769f5f78b22a91eef877cf738186eff9f Mon Sep 17 00:00:00 2001
From: jiangmichaellll <40044148+jiangmichaellll@users.noreply.github.com>
Date: Wed, 16 Jun 2021 19:15:56 -0400
Subject: [PATCH] deps: update dependency
com.google.cloud:google-cloud-pubsublite to v0.16.0 (#202)
* update
* update
---
pom.xml | 2 +-
samples/snapshot/pom.xml | 2 +-
samples/snippets/pom.xml | 2 +-
.../spark/internal/PartitionSubscriberFactory.java | 6 ++----
4 files changed, 5 insertions(+), 7 deletions(-)
diff --git a/pom.xml b/pom.xml
index ec9989e5..2de100d1 100644
--- a/pom.xml
+++ b/pom.xml
@@ -43,7 +43,7 @@
com.google.cloud
google-cloud-pubsublite
- 0.15.0
+ 0.16.0
com.google.api.grpc
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 @@
com.google.cloud
google-cloud-pubsublite
- 0.14.2
+ 0.16.0
junit
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 @@
com.google.cloud
google-cloud-pubsublite
- 0.14.2
+ 0.16.0
junit
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> message_consumer)
+ Partition partition, Offset offset, Consumer> message_consumer)
throws ApiException;
}