deps: update google-cloud-pubsublite to v0.15.0 (#147)

* deps: update google-cloud-pubsublite to v0.15.0 * Set initial seek in the SubscriberBuilder
googleapis · Jun 10, 2021 · c0e7736 · c0e7736
1 parent 7a3932e
commit c0e7736
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/pom.xml b/pom.xml
@@ -17,12 +17,12 @@
     <dependency>
       <groupId>com.google.api.grpc</groupId>
       <artifactId>proto-google-cloud-pubsublite-v1</artifactId>
-      <version>0.14.2</version>
+      <version>0.15.0</version>
     </dependency>
     <dependency>
       <groupId>com.google.cloud</groupId>
       <artifactId>google-cloud-pubsublite</artifactId>
-      <version>0.14.2</version>
+      <version>0.15.0</version>
     </dependency>
     <dependency>
       <groupId>org.apache.kafka</groupId>

diff --git a/src/main/java/com/google/cloud/pubsublite/kafka/ConsumerSettings.java b/src/main/java/com/google/cloud/pubsublite/kafka/ConsumerSettings.java
@@ -118,13 +118,14 @@ public Consumer<byte[], byte[]> instantiate() throws ApiException {
                                         PubsubContext.of(FRAMEWORK),
                                         RoutingMetadata.of(subscriptionPath(), partition),
                                         SubscriberServiceSettings.newBuilder()))))
+                        .setInitialLocation(initialSeek)
                         .build();
                   } catch (Throwable t) {
                     throw toCanonical(t).underlying;
                   }
                 };
             return new BufferingPullSubscriber(
-                subscriberFactory, perPartitionFlowControlSettings(), initialSeek);
+                subscriberFactory, perPartitionFlowControlSettings());
           };
       CommitterFactory committerFactory =
           partition -> {