Uses of Class
io.vertx.kafka.client.consumer.OffsetAndTimestamp
-
Packages that use OffsetAndTimestamp Package Description io.vertx.kafka.client.consumer io.vertx.reactivex.kafka.client.consumer io.vertx.rxjava3.kafka.client.consumer -
-
Uses of OffsetAndTimestamp in io.vertx.kafka.client.consumer
Methods in io.vertx.kafka.client.consumer that return OffsetAndTimestamp Modifier and Type Method Description OffsetAndTimestamp
OffsetAndTimestamp. setOffset(long offset)
Set the offsetOffsetAndTimestamp
OffsetAndTimestamp. setTimestamp(long timestamp)
Set the timestampMethods in io.vertx.kafka.client.consumer that return types with arguments of type OffsetAndTimestamp Modifier and Type Method Description Future<OffsetAndTimestamp>
KafkaConsumer. offsetsForTimes(TopicPartition topicPartition, Long timestamp)
Look up the offset for the given partition by timestamp.Future<Map<TopicPartition,OffsetAndTimestamp>>
KafkaConsumer. offsetsForTimes(Map<TopicPartition,Long> topicPartitionTimestamps)
Look up the offsets for the given partitions by timestamp.Constructors in io.vertx.kafka.client.consumer with parameters of type OffsetAndTimestamp Constructor Description OffsetAndTimestamp(OffsetAndTimestamp that)
Constructor (copy) -
Uses of OffsetAndTimestamp in io.vertx.reactivex.kafka.client.consumer
Methods in io.vertx.reactivex.kafka.client.consumer that return types with arguments of type OffsetAndTimestamp Modifier and Type Method Description Future<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. -
Uses of OffsetAndTimestamp in io.vertx.rxjava3.kafka.client.consumer
Methods in io.vertx.rxjava3.kafka.client.consumer that return types with arguments of type OffsetAndTimestamp Modifier and Type Method 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.
-