Skip to content

Commit a2875bc

Browse files
deps: version bump kafka to the latest version (#341)
1 parent 06a376e commit a2875bc

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@
2727
<dependency>
2828
<groupId>org.apache.kafka</groupId>
2929
<artifactId>kafka-clients</artifactId>
30-
<version>3.1.0</version>
30+
<version>3.2.3</version>
3131
</dependency>
3232
<dependency>
3333
<groupId>com.google.api</groupId>

src/main/java/com/google/cloud/pubsublite/kafka/PubsubLiteConsumer.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -597,6 +597,11 @@ public void enforceRebalance() {
597597
logger.atWarning().log("Calling enforceRebalance on a Pub/Sub Lite Consumer is a no-op.");
598598
}
599599

600+
@Override
601+
public void enforceRebalance(String reason) {
602+
logger.atWarning().log("Calling enforceRebalance on a Pub/Sub Lite Consumer is a no-op.");
603+
}
604+
600605
@Override
601606
public OptionalLong currentLag(TopicPartition topicPartition) {
602607
logger.atWarning().log("Calling currentLag on a Pub/Sub Lite Consumer always returns empty.");

0 commit comments

Comments
 (0)