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 © 2023 Eclipse. All rights reserved.