| Package | Description |
|---|---|
| io.vertx.kafka.admin | |
| io.vertx.kafka.admin.impl | |
| io.vertx.kafka.client.common.impl |
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
Future<Map<TopicPartition,ListOffsetsResultInfo>> |
KafkaAdminClientImpl.listOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets) |
void |
KafkaAdminClientImpl.listOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets,
Handler<AsyncResult<Map<TopicPartition,ListOffsetsResultInfo>>> completionHandler) |
| Modifier and Type | Method and Description |
|---|---|
static org.apache.kafka.clients.admin.OffsetSpec |
Helper.to(OffsetSpec os) |
| Modifier and Type | Method and Description |
|---|---|
static Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.admin.OffsetSpec> |
Helper.toTopicPartitionOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets) |
Copyright © 2021. All rights reserved.