From 459efb02ad243e87f42caffcf4f3a0004c41ccd6 Mon Sep 17 00:00:00 2001 From: Jason Gustafson Date: Thu, 26 Apr 2018 06:58:36 -0700 Subject: [PATCH] HOTFIX: ListConsumerGroupsResult should use KafkaFuture (#4933) --- .../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 0ac852945f6..7de485bd2b9 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> all() { + public KafkaFuture> 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> valid() { + public KafkaFuture> 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> errors() { + public KafkaFuture> errors() { return errors; } }