个人名片
🎓作者简介：java领域优质创作者
🌐个人主页：码农阿豪
📞工作室：新空间代码工作室（提供各种软件服务）
💌个人邮箱：[2435024119@qq.com]
📱个人微信：15279484656
🌐个人导航网站：www.forff.top
💡座右铭：总有人要赢。为什么不能是我呢？
- 专栏导航：
码农阿豪系列专栏导航
面试专栏：收集了java相关高频面试题，面试实战总结🍻🎉🖥️
Spring5系列专栏：整理了Spring5重要知识点与实战演练，有案例可直接使用🚀🔧💻
Redis专栏：Redis从零到一学习分享，经验总结，案例实战💐📝💡
全栈系列专栏：海纳百川有容乃大，可能你想要的东西里面都有🤸🌱🚀
目录
- 使用命令行工具查询Kafka集群信息
- 1. 查询消费组信息
- 2. 查询消费组详细信息
- 使用Kafka Manager管理工具
- 1. 安装Kafka Manager
- 2. 配置Kafka Manager
- 总结
要查询Kafka集群中消费组（group）信息和对应topic的消费情况，你可以使用Kafka自带的工具以及Kafka的管理工具，比如Kafka Manager。下面是详细的步骤，包括使用命令行工具和代码示例来获取这些信息，
使用命令行工具查询Kafka集群信息
1. 查询消费组信息
使用以下命令可以列出所有的消费组：
bin/kafka-consumer-groups.sh --bootstrap-server <kafka_broker_list> --list
例如，如果你的Kafka集群有三个broker，地址为kafka1:9092,kafka2:9092,kafka3:9092，你可以使用以下命令：
bin/kafka-consumer-groups.sh --bootstrap-server kafka1:9092,kafka2:9092,kafka3:9092 --list
2. 查询消费组详细信息
使用以下命令可以查看某个消费组的详细信息，包括它订阅的topic及其消费情况：
bin/kafka-consumer-groups.sh --bootstrap-server <kafka_broker_list> --describe --group <group_id>
例如，要查看名为my-group的消费组的信息，可以使用以下命令：
bin/kafka-consumer-groups.sh --bootstrap-server kafka1:9092,kafka2:9092,kafka3:9092 --describe --group my-group
使用Kafka Manager管理工具
Kafka Manager是一个开源的Kafka集群管理工具，可以通过Web界面方便地管理和监控Kafka集群。安装和配置Kafka Manager之后，你可以通过Web界面查看消费组和topic的详细信息。
1. 安装Kafka Manager
你可以通过以下命令来安装Kafka Manager：
git clone https://github.com/yahoo/kafka-manager.git
cd kafka-manager
./sbt clean dist
然后解压生成的压缩包并启动Kafka Manager：
unzip target/universal/kafka-manager-<version>.zip
cd kafka-manager-<version>
bin/kafka-manager
2. 配置Kafka Manager
启动Kafka Manager之后，打开Web浏览器访问http://<kafka_manager_host>:9000，添加Kafka集群配置。例如：
- Cluster Name: my-kafka-cluster
- Zookeeper Hosts: zookeeper1:2181,zookeeper2:2181,zookeeper3:2181
- Enable JMX Polling: true
配置完成后，你可以在Web界面上查看和管理Kafka集群的信息，包括消费组和topic的消费情况。
总结
通过上述方法，可以方便地查询Kafka集群中的消费组信息和topic的消费情况，从而更好地管理和监控Kafka集群的运行状态。
希望这篇博客对你有所帮助！如果有更多问题，欢迎留言讨论。
