kafka消费者组管理实战

kafka topic管理命令（启动生产者，消费者） : 连接

1.查看现有的消费者组

kafka-consumer-groups.sh --bootstrap-server  10.0.0.111:9092 --list

2列出所有的消费者组信息。

kafka-consumer-groups.sh --bootstrap-server  10.0.0.111:9092 --describe --all-groups 

3 列出所有消费者组的详细信息，包括偏移量，消费者ID，LEO等信息。

kafka-console-consumer.sh --bootstrap-server 10.0.0.111:9092,10.0.0.112:9092 --topic __consumer_offsets --formatter "kafka.coordinator.group.GroupMetadataManager\$OffsetsMessageFormatter"   --from-beginning

查看内置topic的offset数据，了解即可。

二.基于配置文件指定消费者组

vim $KAFKA_HOME/config/consumer.properties

...

指定消费者组的名称

group.id=baimei-dashu86
[root@elk111 ~]#
[root@elk111 ~]#

指定 配置文件运行

kafka-console-consumer.sh --bootstrap-server 10.0.0.112:9092 --topic baimei-dashu86 --consumer.config $KAFKA_HOME/config/consumer.properties

然后我们 生产数据看看

kafka-console-producer.sh --bootstrap-server 10.0.0.111:9092 --topic baimei-dashu86 

三、.基于命令行参数指定消费者组

kafka-console-consumer.sh --bootstrap-server 10.0.0.112:9092 --topic baimei-dashu86 --consumer-property group.id=baimei-dashu86

我们在另一个终端在 次启动一个消费者：

欢迎来撩： 消息队列kafka 汇总