[kafka] branch trunk updated: HOTFIX: ListConsumerGroupsResult should use KafkaFuture (#4933)

[gu...@apache.org]

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 459efb0  HOTFIX: ListConsumerGroupsResult should use KafkaFuture (#4933)
459efb0 is described below

commit 459efb02ad243e87f42caffcf4f3a0004c41ccd6
Author: Jason Gustafson <ja...@confluent.io>
AuthorDate: Thu Apr 26 06:58:36 2018 -0700

    HOTFIX: ListConsumerGroupsResult should use KafkaFuture (#4933)
---
 .../org/apache/kafka/clients/admin/ListConsumerGroupsResult.java    | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupsResult.java b/clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupsResult.java
index 0ac8529..7de485b 100644
--- a/clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupsResult.java
+++ b/clients/src/main/java/org/apache/kafka/clients/admin/ListConsumerGroupsResult.java
@@ -70,7 +70,7 @@ public class ListConsumerGroupsResult {
      * In the event of a failure, the future yields nothing but the first exception which
      * occurred.
      */
-    public KafkaFutureImpl<Collection<ConsumerGroupListing>> all() {
+    public KafkaFuture<Collection<ConsumerGroupListing>> all() {
         return all;
     }
 
@@ -83,7 +83,7 @@ public class ListConsumerGroupsResult {
      * those partial results.  When using this future, it is a good idea to also check
      * the errors future so that errors can be displayed and handled.
      */
-    public KafkaFutureImpl<Collection<ConsumerGroupListing>> valid() {
+    public KafkaFuture<Collection<ConsumerGroupListing>> valid() {
         return valid;
     }
 
@@ -96,7 +96,7 @@ public class ListConsumerGroupsResult {
      * This future itself never fails with an error.  In the event of an error, this future
      * will successfully yield a collection containing at least one exception.
      */
-    public KafkaFutureImpl<Collection<Throwable>> errors() {
+    public KafkaFuture<Collection<Throwable>> errors() {
         return errors;
     }
 }

-- 
To stop receiving notification emails like this one, please contact
guozhang@apache.org.