我按照快速入门指南在此本地运行了kafka,
然后我在config/consumer.properties
中定义了我的消费者组配置,以便我的消费者可以从定义的group.id
中接收消息。
运行以下命令:
bin/kafka-consumer-groups.sh --list --bootstrap-server localhost:9092
导致,
test-consumer-group <-- group.id defined in conf/consumer.properties
console-consumer-67807 <-- when connecting to kafka via kafka-console-consumer.sh
我能够通过一个基于Python的消费者连接到 Kafka,该消费者配置了使用提供的group.id
,即test-consumer-group
。
首先,我不理解 Kafka 是如何/何时创建消费者组的。它似乎在某个时刻加载conf/consumer.properties
文件,并在通过kafka-console-consumer.sh
进行连接时隐式地创建消费者组(在我的情况下是console-consumer-67807
)。
我该如何显式地创建自己的消费者组,比如说my-created-consumer-group
?
my-created-consumer-group
,那么上述命令是否有效?换句话说,如果一个消费者连接到任意的 group.id,kafka 是否会接受并创建消费者组? - laxman