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.