Kafka consumer Поведение

Question

Я писал потребитель Кафки, и у меня есть запрос, связанный с потребительскими процессами.

У меня есть потребитель с groupId="testGroupId" и используя ту же группу. Я использую из нескольких тем, скажем, "topic1" и "topic2".

Кроме того, предположим, что "topic1" уже создано на брокере, тогда как "topic2" еще не создан.

Теперь, если я запускаю потребитель, я вижу потребительские потоки для "topic1" (который уже создан) в узлах zookeeper, но я не вижу ни одного потребительского потока (-ов) для "topic2".

Мой вопрос: будет ли потребительский поток (-ы) для "topic2" создан только после того, как мы создадим тему для брокера?

Answer 1

Предполагаете, вы используете Kafka ConsumerConnector способ как createMessageStreamsByFilter. Потребитель будет подписаться на тематические события кафки, и в случае новых тем он автоматически подпишет эту тему.