卡夫卡定制消费者阅读传入记录

Question

我已经使用新的API（http://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html）

目前消费者正在读读书从主题从最小的偏移开始的消息创造了卡夫卡的消费者。我想覆盖这个从最新的偏移量中读取。任何关于如何完成的指针？

Answer 1

一旦您开始阅读给定使用者组的消息，您需要明确强制使用者到seekToEnd（）方法所在分区的末尾。对于尚未读取任何消息的消费者组，您可以使用auto.offset.reset = largest属性告诉消费者在哪里阅读其第一封消息。

Answer 2

尝试设置auto.offset.reset = largest，虽然这应该是默认设置。