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 |
---|---|
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 © 2024 Eclipse. All rights reserved.