| Package | Description | 
|---|---|
| io.vertx.kafka.admin | 
| Modifier and Type | Method and Description | 
|---|---|
ConsumerGroupDescription | 
ConsumerGroupDescription.setCoordinator(Node coordinator)
Set the consumer group coordinator, or null if the coordinator is not known 
 | 
ConsumerGroupDescription | 
ConsumerGroupDescription.setGroupId(String groupId)
Set the id of the consumer group 
 | 
ConsumerGroupDescription | 
ConsumerGroupDescription.setMembers(List<MemberDescription> members)
Set a list of the members of the consumer group 
 | 
ConsumerGroupDescription | 
ConsumerGroupDescription.setPartitionAssignor(String partitionAssignor)
Set the consumer group partition assignor 
 | 
ConsumerGroupDescription | 
ConsumerGroupDescription.setSimpleConsumerGroup(boolean isSimpleConsumerGroup)
Set if consumer group is simple or not 
 | 
ConsumerGroupDescription | 
ConsumerGroupDescription.setState(org.apache.kafka.common.ConsumerGroupState state)
Set the consumer group state, or UNKNOWN if the state is too new for us to parse 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
ConsumerGroupDescriptionConverter.fromJson(Iterable<Map.Entry<String,Object>> json,
        ConsumerGroupDescription obj)  | 
static void | 
ConsumerGroupDescriptionConverter.toJson(ConsumerGroupDescription obj,
      JsonObject json)  | 
static void | 
ConsumerGroupDescriptionConverter.toJson(ConsumerGroupDescription obj,
      Map<String,Object> json)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
KafkaAdminClient.describeConsumerGroups(List<String> groupIds,
                      Handler<AsyncResult<Map<String,ConsumerGroupDescription>>> completionHandler)
Describe some group ids in the cluster, with the default options 
 | 
Copyright © 2020 Eclipse. All rights reserved.