deps: version bump kafka to the latest version (#341)

googleapis · Sep 21, 2022 · a2875bc · a2875bc
1 parent 06a376e
commit a2875bc
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/pom.xml b/pom.xml
@@ -27,7 +27,7 @@
     <dependency>
       <groupId>org.apache.kafka</groupId>
       <artifactId>kafka-clients</artifactId>
-      <version>3.1.0</version>
+      <version>3.2.3</version>
     </dependency>
     <dependency>
       <groupId>com.google.api</groupId>

diff --git a/src/main/java/com/google/cloud/pubsublite/kafka/PubsubLiteConsumer.java b/src/main/java/com/google/cloud/pubsublite/kafka/PubsubLiteConsumer.java
@@ -597,6 +597,11 @@ public void enforceRebalance() {
     logger.atWarning().log("Calling enforceRebalance on a Pub/Sub Lite Consumer is a no-op.");
   }
 
+  @Override
+  public void enforceRebalance(String reason) {
+    logger.atWarning().log("Calling enforceRebalance on a Pub/Sub Lite Consumer is a no-op.");
+  }
+
   @Override
   public OptionalLong currentLag(TopicPartition topicPartition) {
     logger.atWarning().log("Calling currentLag on a Pub/Sub Lite Consumer always returns empty.");