static void |
ListConsumerGroupOffsetsOptionsConverter.fromJson(Iterable<Map.Entry<String,Object>> json,
ListConsumerGroupOffsetsOptions obj) |
Future<Map<TopicPartition,OffsetAndMetadata>> |
KafkaAdminClient.listConsumerGroupOffsets(String groupId,
ListConsumerGroupOffsetsOptions options)
|
void |
KafkaAdminClient.listConsumerGroupOffsets(String groupId,
ListConsumerGroupOffsetsOptions options,
Handler<AsyncResult<Map<TopicPartition,OffsetAndMetadata>>> completionHandler)
List the consumer group offsets available in the cluster.
|
static void |
ListConsumerGroupOffsetsOptionsConverter.toJson(ListConsumerGroupOffsetsOptions obj,
JsonObject json) |
static void |
ListConsumerGroupOffsetsOptionsConverter.toJson(ListConsumerGroupOffsetsOptions obj,
Map<String,Object> json) |