Package | Description |
---|---|
io.vertx.kafka.admin |
Modifier and Type | Method and Description |
---|---|
ListOffsetsResultInfo |
ListOffsetsResultInfo.setLeaderEpoch(Integer leaderEpoch)
Set the leader epoch
|
ListOffsetsResultInfo |
ListOffsetsResultInfo.setOffset(long offset)
Set the offset
|
ListOffsetsResultInfo |
ListOffsetsResultInfo.setTimestamp(long timestamp)
Set the timestamp
|
Modifier and Type | Method and Description |
---|---|
Future<Map<TopicPartition,ListOffsetsResultInfo>> |
KafkaAdminClient.listOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets)
Like
#listOffsets(Map but returns a Future of the asynchronous result |
Modifier and Type | Method and Description |
---|---|
static void |
ListOffsetsResultInfoConverter.fromJson(Iterable<Map.Entry<String,Object>> json,
ListOffsetsResultInfo obj) |
static void |
ListOffsetsResultInfoConverter.toJson(ListOffsetsResultInfo obj,
JsonObject json) |
static void |
ListOffsetsResultInfoConverter.toJson(ListOffsetsResultInfo obj,
Map<String,Object> json) |
Modifier and Type | Method and Description |
---|---|
void |
KafkaAdminClient.listOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets,
Handler<AsyncResult<Map<TopicPartition,ListOffsetsResultInfo>>> completionHandler)
List the offsets available for a set of partitions.
|
Copyright © 2021 Eclipse. All rights reserved.