白眉大叔 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 汇总
欢迎来撩 ： 汇总all
