使用Kafka和Zookeeper，不同的組ID從一開始就不檢索卡夫卡消息

我們有kafka v2.10和zookeeper v3.4設置和工作。我們編寫了高級消費者消費卡夫卡的日誌消息。消費者A開始使用主題T和組ID爲G1的消息（遵循Apache Kafka文檔中提供的高級消費者示例）。然後，當消費者B帶同一主題噸，但組ID G2啓動時，它連接到卡夫卡/飼養員，但耗費數封郵件開始使用Kafka和Zookeeper，不同的組ID從一開始就不檢索卡夫卡消息

我的理解是消費者使用A.最後一個之後的偏移量，它應該給出日誌消息，以該主題中卡夫卡中可用的最低偏移量開始。任何想法爲什麼它沒有這樣做？

我們不復制卡夫卡或動物園管理員呢。此時建立的OUr簡單而直接，我們正試圖讓他們使用基本功能。

任何幫助表示讚賞。

另外，你知道我們在哪裏可以找到新的目錄，據說zookeeper每創建一個消費者與新的組ID與zookeeper建立連接（用於追蹤該組ID的連接）？

來源

2015-01-07 FZF

你可以嘗試在創建消費羣

props.put("auto.offset.reset", "smallest");

來源

2015-01-07 14:38:33 user2720864

非常感謝，認爲這樣做是增加這配置。你知道如何在zookeeper客戶端中顯示消費者groupid爲主題讀取的最後偏移量。它必須將其保存到某個位置，以便知道消費者羣組開始使用的下一個偏移量。 – FZF

我建議你爲此單獨提出一個問題..但在此之前，請通過http://kafka.apache.org/08/documentation.html#distributionimpl對zookeeper如何參與這一過程有一個基本的瞭解 – user2720864

使用Kafka和Zookeeper，不同的組ID從一開始就不檢索卡夫卡消息

回答

相關問題