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