Package | Description |
---|---|
io.vertx.kafka.admin | |
io.vertx.reactivex.kafka.admin | |
io.vertx.rxjava.kafka.admin | |
io.vertx.rxjava3.kafka.admin |
Modifier and Type | Method and Description |
---|---|
ConsumerGroupDescription |
ConsumerGroupDescription.setAuthorizedOperations(Set<org.apache.kafka.common.acl.AclOperation> authorizedOperations)
Set the id of the consumer group
|
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 |
---|---|
Future<Map<String,ConsumerGroupDescription>> |
KafkaAdminClient.describeConsumerGroups(List<String> groupIds)
Like
KafkaAdminClient.describeConsumerGroups(List, Handler) but returns a Future of the asynchronous result |
Future<Map<String,ConsumerGroupDescription>> |
KafkaAdminClient.describeConsumerGroups(List<String> groupIds,
DescribeConsumerGroupsOptions options)
Like
KafkaAdminClient.describeConsumerGroups(List, DescribeConsumerGroupsOptions, Handler) but returns a Future of the asynchronous result |
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,
DescribeConsumerGroupsOptions options,
Handler<AsyncResult<Map<String,ConsumerGroupDescription>>> completionHandler)
Like
KafkaAdminClient.describeConsumerGroups(List, Handler) but allows customized options |
void |
KafkaAdminClient.describeConsumerGroups(List<String> groupIds,
Handler<AsyncResult<Map<String,ConsumerGroupDescription>>> completionHandler)
Describe some group ids in the cluster, with the default options
|
Modifier and Type | Method and Description |
---|---|
Single<Map<String,ConsumerGroupDescription>> |
KafkaAdminClient.rxDescribeConsumerGroups(List<String> groupIds)
Describe some group ids in the cluster, with the default options
|
Single<Map<String,ConsumerGroupDescription>> |
KafkaAdminClient.rxDescribeConsumerGroups(List<String> groupIds,
DescribeConsumerGroupsOptions options)
|
Modifier and Type | Method and Description |
---|---|
void |
KafkaAdminClient.describeConsumerGroups(List<String> groupIds,
DescribeConsumerGroupsOptions options,
Handler<AsyncResult<Map<String,ConsumerGroupDescription>>> completionHandler)
|
void |
KafkaAdminClient.describeConsumerGroups(List<String> groupIds,
Handler<AsyncResult<Map<String,ConsumerGroupDescription>>> completionHandler)
Describe some group ids in the cluster, with the default options
|
Modifier and Type | Method and Description |
---|---|
Single<Map<String,ConsumerGroupDescription>> |
KafkaAdminClient.rxDescribeConsumerGroups(List<String> groupIds)
Describe some group ids in the cluster, with the default options
|
Single<Map<String,ConsumerGroupDescription>> |
KafkaAdminClient.rxDescribeConsumerGroups(List<String> groupIds,
DescribeConsumerGroupsOptions options)
|
Modifier and Type | Method and Description |
---|---|
void |
KafkaAdminClient.describeConsumerGroups(List<String> groupIds,
DescribeConsumerGroupsOptions options,
Handler<AsyncResult<Map<String,ConsumerGroupDescription>>> completionHandler)
|
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.