Package | Description |
---|---|
io.vertx.kafka.admin |
Modifier and Type | Field and Description |
---|---|
static OffsetSpec |
OffsetSpec.EARLIEST |
static OffsetSpec |
OffsetSpec.LATEST |
Modifier and Type | Method and Description |
---|---|
OffsetSpec |
OffsetSpec.setSpec(long spec)
Set the offset spec
|
static OffsetSpec |
OffsetSpec.TIMESTAMP(long timestamp) |
Modifier and Type | Method and Description |
---|---|
static void |
OffsetSpecConverter.fromJson(Iterable<Map.Entry<String,Object>> json,
OffsetSpec obj) |
static void |
OffsetSpecConverter.toJson(OffsetSpec obj,
JsonObject json) |
static void |
OffsetSpecConverter.toJson(OffsetSpec obj,
Map<String,Object> json) |
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 |
void |
KafkaAdminClient.listOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets,
Handler<AsyncResult<Map<TopicPartition,ListOffsetsResultInfo>>> completionHandler)
List the offsets available for a set of partitions.
|
Copyright © 2023 Eclipse. All rights reserved.