我正在使用卡夫卡0.9。我想知道是否有任何方法通過了解分區和偏移量從其主題中檢索已處理的消息。例如,消費者正在消費分區1和偏移10處的消息。並且我想在相同分區和偏移5處獲得消息。通過了解卡夫卡的分區和偏移量來獲取消息
我能想到的一種方法是將偏移重置爲5並消耗一條消息。但是poll()方法只能返回一批消息。所以我必須先聽取第一條信息,不要理睬其他人。處理完消息後,偏移被重置。
我認爲這會奏效。但仍然想知道是否有其他優雅的方式。
我正在使用卡夫卡0.9。我想知道是否有任何方法通過了解分區和偏移量從其主題中檢索已處理的消息。例如,消費者正在消費分區1和偏移10處的消息。並且我想在相同分區和偏移5處獲得消息。通過了解卡夫卡的分區和偏移量來獲取消息
我能想到的一種方法是將偏移重置爲5並消耗一條消息。但是poll()方法只能返回一批消息。所以我必須先聽取第一條信息,不要理睬其他人。處理完消息後,偏移被重置。
我認爲這會奏效。但仍然想知道是否有其他優雅的方式。
您應該能夠使用「seek」方法從您需要的偏移量中讀取消息。
看看「控制消費者的立場」 https://kafka.apache.org/090/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html
'但是poll()方法只能一批messages'返回 - >如果你不設置batch.size 0 – C4stor