| 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 | 
|---|---|
void | 
KafkaAdminClient.listOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets,
           Handler<AsyncResult<Map<TopicPartition,ListOffsetsResultInfo>>> completionHandler)
List the offsets available for a set of partitions. 
 | 
Copyright © 2020 Eclipse. All rights reserved.