卡夫卡消費者行爲

Question

我在寫卡夫卡消費者，我有一個與消費者流程相關的查詢。

我有一個消費者groupId="testGroupId"和使用相同的groupId我從多個主題消費說，"topic1"和"topic2"。

此外，假設"topic1"已經在經紀人上創建，而"topic2"尚未創建。

現在，如果我啓動消費者，我會在zookeeper節點中看到"topic1"（已創建）的消費者線程，但我沒有看到"topic2"的任何消費者線程。

我的問題是，"topic2"的消費者線程是否只有在我們在經紀人上創建主題後纔會創建？

Answer 1

我假設你使用卡夫卡ConsumerConnector方法如createMessageStreamsByFilter。消費者將訂閱kafka話題事件，如果有新話題，它將自動訂閱該話題。