diff --git a/pom.xml b/pom.xml index c4b0eba4..de1db08b 100644 --- a/pom.xml +++ b/pom.xml @@ -17,12 +17,12 @@ com.google.api.grpc proto-google-cloud-pubsublite-v1 - 0.14.2 + 0.15.0 com.google.cloud google-cloud-pubsublite - 0.14.2 + 0.15.0 org.apache.kafka diff --git a/src/main/java/com/google/cloud/pubsublite/kafka/ConsumerSettings.java b/src/main/java/com/google/cloud/pubsublite/kafka/ConsumerSettings.java index f7b123b0..6e53853b 100644 --- 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 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 -> {