卡夫卡定製消費者閱讀傳入記錄

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，雖然這應該是默認設置。