卡夫卡消费者行为

Question

我正在编写 Kafka 消费者，我有一个与消费者进程相关的查询。

我有一个消费者 groupId="testGroupId" 并使用我从多个主题消费的相同 groupId，例如 "topic1" 和 "topic2"。

另外，假设 "topic1" 已在代理上创建，而 "topic2" 尚未创建。

现在，如果我启动消费者，我会在 zookeeper 节点中看到 "topic1"（已创建）的消费者线程，但我看不到 "topic2" 的任何消费者线程。

我的问题是，"topic2" 的消费者线程是否只有在我们在代理上创建主题后才会创建？

Answer 1

我假设你使用像 createMessageStreamsByFilter 这样的 Kafka ConsumerConnector 方法。消费者将订阅 kafka 主题事件，如果有新主题，它将自动订阅该主题。