[kafka] branch trunk updated: HOTFIX: KIP-851, rename requireStable in ListConsumerGroupOffsetsOptions

[guozhang]

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 <wangg...@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;
     }
 }