卡夫卡10.2新消費者與舊消費者

Question

我花了幾個小時弄清楚發生了什麼，但沒有找到解決方案。

這是我設置了一臺機器上：

• 1飼養員運行
• 3經紀人運行（端口9092/9093/9094）
• 1與3個分區，三次重複（話題每個分區在代理之間正確分配）

我正在使用卡夫卡控制檯生產者插入消息。如果我檢查複製偏移量（cat replication-offset-checkpoint），我看到我的消息被卡夫卡正確攝取。

現在我用的是卡夫卡控制檯消費者（新）：

sudo bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic testTopicPartitionned2 

我沒有看到任何消耗。我試圖刪除我的日誌文件夾（/ tmp/kafka-logs- [1,2,3]），創建新的主題，仍然沒有。

然而，當我使用舊的卡夫卡消費者：

sudo bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic testTopicPartitionned2 

我可以看到我的消息。

我在這裏錯過了什麼東西讓這個新的消費者工作？

在此先感謝。

Answer 1

嘗試提供你所有的經紀--bootstrap-server參數看，如果你發現任何differnce：

sudo bin/kafka-console-consumer.sh --bootstrap-server localhost:9092,localhost:9093,localhost:9094 --from-beginning --topic testTopicPartitionned2 

還有，你的主題名稱比較長。我假設你已經確保你提供了正確的主題名稱。

Answer 2

檢查，看看有什麼設置消費者使用auto.offset.reset財產

這會影響什麼沒有以前提交的偏移的消費羣將在設置方面做的哪裏開始從一個分區讀取消息。

查看卡夫卡文檔瞭解更多信息。