abstract fun seekToEnd(topicPartition: TopicPartition): KafkaConsumer<K, V>
Seek to the last offset for each of the given partition.
topicPartition - topic partition for which seek
Return
current KafkaConsumer instance
abstract fun seekToEnd(topicPartitions: MutableSet<TopicPartition>): KafkaConsumer<K, V>
Seek to the last offset for each of the given partitions.
topicPartitions - topic partition for which seek
Return
current KafkaConsumer instance
abstract fun seekToEnd(topicPartition: TopicPartition, completionHandler: Handler<AsyncResult<Void>>): KafkaConsumer<K, V>
Seek to the last offset for each of the given partition.
topicPartition - topic partition for which seek
completionHandler - handler called on operation completed
Return
current KafkaConsumer instance
abstract fun seekToEnd(topicPartitions: MutableSet<TopicPartition>, completionHandler: Handler<AsyncResult<Void>>): KafkaConsumer<K, V>
Seek to the last offset for each of the given partitions.
topicPartitions - topic partition for which seek
completionHandler - handler called on operation completed
Return
current KafkaConsumer instance