Kafka - 知道消費者是否是最新的

Question

我正在使用Kafka 0.9.0與原生Java消費者客戶端。 如果我有1個主題與1個分區 有人可以告訴我，如果我這樣做： seekToEnd（MyTopic）; poll（x）;

我只會得到最後的記錄，因此我會知道我處於最後的位置？

Answer 1

是的，你只會得到最後一個（最新）的記錄，因爲seekToEnd()法「評估懶洋洋地」，所以不計算月底至poll()被調用。當然，到poll()方法返回時，可能會添加更多的消息;所以不能保證你的偏移量「處於最後位置」，除非該方法執行時。