Package | Description |
---|---|
io.vertx.kafka.admin |
Modifier and Type | Method and Description |
---|---|
MemberDescription |
MemberDescription.setAssignment(MemberAssignment assignment)
Set the assignment of the group member
|
MemberDescription |
MemberDescription.setClientId(String clientId)
Set the client id of the group member
|
MemberDescription |
MemberDescription.setConsumerId(String consumerId)
Set the consumer id of the group member
|
MemberDescription |
MemberDescription.setHost(String host)
Set the host where the group member is running
|
Modifier and Type | Method and Description |
---|---|
List<MemberDescription> |
ConsumerGroupDescription.getMembers() |
Modifier and Type | Method and Description |
---|---|
static void |
MemberDescriptionConverter.fromJson(Iterable<Map.Entry<String,Object>> json,
MemberDescription obj) |
static void |
MemberDescriptionConverter.toJson(MemberDescription obj,
JsonObject json) |
static void |
MemberDescriptionConverter.toJson(MemberDescription obj,
Map<String,Object> json) |
Modifier and Type | Method and Description |
---|---|
ConsumerGroupDescription |
ConsumerGroupDescription.setMembers(List<MemberDescription> members)
Set a list of the members of the consumer group
|
Constructor and Description |
---|
ConsumerGroupDescription(String groupId,
boolean isSimpleConsumerGroup,
List<MemberDescription> members,
String partitionAssignor,
org.apache.kafka.common.ConsumerGroupState state,
Node coordinator,
Set<org.apache.kafka.common.acl.AclOperation> authorizedOperations)
Constructor
|
Copyright © 2023 Eclipse. All rights reserved.