| Package | Description | 
|---|---|
| io.vertx.kafka.client.consumer | |
| io.vertx.reactivex.kafka.client.consumer | |
| io.vertx.rxjava.kafka.client.consumer | |
| io.vertx.rxjava3.kafka.client.consumer | 
| Modifier and Type | Method and Description | 
|---|---|
OffsetAndTimestamp | 
OffsetAndTimestamp.setOffset(long offset)
Set the offset 
 | 
OffsetAndTimestamp | 
OffsetAndTimestamp.setTimestamp(long timestamp)
Set the timestamp 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Future<Map<TopicPartition,OffsetAndTimestamp>> | 
KafkaConsumer.offsetsForTimes(Map<TopicPartition,Long> topicPartitionTimestamps)
Like  
KafkaConsumer.offsetsForTimes(Map, Handler) but returns a Future of the asynchronous result | 
Future<OffsetAndTimestamp> | 
KafkaConsumer.offsetsForTimes(TopicPartition topicPartition,
               Long timestamp)
Like  
KafkaConsumer.offsetsForTimes(TopicPartition, Long, Handler) but returns a Future of the asynchronous result | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
KafkaConsumer.offsetsForTimes(Map<TopicPartition,Long> topicPartitionTimestamps,
               Handler<AsyncResult<Map<TopicPartition,OffsetAndTimestamp>>> handler)
Look up the offsets for the given partitions by timestamp. 
 | 
void | 
KafkaConsumer.offsetsForTimes(TopicPartition topicPartition,
               Long timestamp,
               Handler<AsyncResult<OffsetAndTimestamp>> handler)
Look up the offset for the given partition by timestamp. 
 | 
| Constructor and Description | 
|---|
OffsetAndTimestamp(OffsetAndTimestamp that)
Constructor (copy) 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Single<OffsetAndTimestamp> | 
KafkaConsumer.rxOffsetsForTimes(TopicPartition topicPartition,
                 Long timestamp)
Look up the offset for the given partition by timestamp. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
KafkaConsumer.offsetsForTimes(TopicPartition topicPartition,
               Long timestamp,
               Handler<AsyncResult<OffsetAndTimestamp>> handler)
Look up the offset for the given partition by timestamp. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Single<OffsetAndTimestamp> | 
KafkaConsumer.rxOffsetsForTimes(TopicPartition topicPartition,
                 Long timestamp)
Look up the offset for the given partition by timestamp. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
KafkaConsumer.offsetsForTimes(TopicPartition topicPartition,
               Long timestamp,
               Handler<AsyncResult<OffsetAndTimestamp>> handler)
Look up the offset for the given partition by timestamp. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Single<OffsetAndTimestamp> | 
KafkaConsumer.offsetsForTimes(TopicPartition topicPartition,
               Long timestamp)
Look up the offset for the given partition by timestamp. 
 | 
Single<OffsetAndTimestamp> | 
KafkaConsumer.rxOffsetsForTimes(TopicPartition topicPartition,
                 Long timestamp)
Look up the offset for the given partition by timestamp. 
 | 
Copyright © 2022 Eclipse. All rights reserved.