要查询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集群的运行状态。
希望这篇博客对你有所帮助！如果有更多问题，欢迎留言讨论。
