You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2022/07/07 05:00:44 UTC
[kafka] branch trunk updated: HOTFIX: KIP-851, rename requireStable in ListConsumerGroupOffsetsOptions
This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new ca8135b242a HOTFIX: KIP-851, rename requireStable in ListConsumerGroupOffsetsOptions
ca8135b242a is described below
commit ca8135b242a5d5fd71e5edffbcb85ada2f5d9bd2
Author: Guozhang Wang <wa...@gmail.com>
AuthorDate: Wed Jul 6 22:00:31 2022 -0700
HOTFIX: KIP-851, rename requireStable in ListConsumerGroupOffsetsOptions
---
.../src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java | 2 +-
.../org/apache/kafka/clients/admin/ListConsumerGroupOffsetsOptions.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java b/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
index 99fd98b443f..aad2610c94a 100644
--- a/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
+++ b/clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
@@ -3404,7 +3404,7 @@ public class KafkaAdminClient extends AdminClient {
final ListConsumerGroupOffsetsOptions options) {
SimpleAdminApiFuture<CoordinatorKey, Map<TopicPartition, OffsetAndMetadata>> future =
ListConsumerGroupOffsetsHandler.newFuture(groupId);
- ListConsumerGroupOffsetsHandler handler = new ListConsumerGroupOffsetsHandler(groupId, options.topicPartitions(), options.shouldRequireStable(), logContext);
+ ListConsumerGroupOffsetsHandler handler = new ListConsumerGroupOffsetsHandler(groupId, options.topicPartitions(), options.requireStable(), logContext);
invokeDriver(handler, future, options.timeoutMs);
return new ListConsumerGroupOffsetsResult(future.get(CoordinatorKey.byGroupId(groupId)));
}
diff --git a/clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsOptions.java b/clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsOptions.java
index a06feaf3b38..292a47ef393 100644
--- a/clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsOptions.java
+++ b/clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupOffsetsOptions.java
@@ -60,7 +60,7 @@ public class ListConsumerGroupOffsetsOptions extends AbstractOptions<ListConsume
return topicPartitions;
}
- public boolean shouldRequireStable() {
+ public boolean requireStable() {
return requireStable;
}
}