@Evolving public class DescribeConsumerGroupsResult extends java.lang.Object
KafkaAdminClient.describeConsumerGroups(Collection, DescribeConsumerGroupsOptions)
} call.
The API of this class is evolving, see AdminClient
for details.Constructor | Description |
---|---|
DescribeConsumerGroupsResult(java.util.Map<java.lang.String,KafkaFuture<ConsumerGroupDescription>> futures) |
Modifier and Type | Method | Description |
---|---|---|
KafkaFuture<java.util.Map<java.lang.String,ConsumerGroupDescription>> |
all() |
Return a future which yields all ConsumerGroupDescription objects, if all the describes succeed.
|
java.util.Map<java.lang.String,KafkaFuture<ConsumerGroupDescription>> |
describedGroups() |
Return a map from group id to futures which yield group descriptions.
|
public DescribeConsumerGroupsResult(java.util.Map<java.lang.String,KafkaFuture<ConsumerGroupDescription>> futures)
public java.util.Map<java.lang.String,KafkaFuture<ConsumerGroupDescription>> describedGroups()
public KafkaFuture<java.util.Map<java.lang.String,ConsumerGroupDescription>> all()