Kafka：查看Topic列表、消息消费情况、模拟生产者消费者

要查看Kafka的Topic列表，可以使用Kafka自带的命令行工具kafka-topics.sh。

bin/kafka-topics.sh --list --bootstrap-server <broker-list>

其中 <broker-list> 是Kafka集群中代理的列表，格式为 host1:port,host2:port。

要监控消费情况，可以使用 kafka-consumer-groups.sh 脚本。

bin/kafka-consumer-groups.sh --bootstrap-server <broker-list> --list
bin/kafka-consumer-groups.sh --bootstrap-server <broker-list> --describe --group <group-id>

在这里 <group-id> 是消费者群组的ID。

要模拟生产者行为，可以使用 kafka-console-producer.sh 脚本。

bin/kafka-console-producer.sh --broker-list <broker-list> --topic <topic-name>

要模拟消费者行为，可以使用 kafka-console-consumer.sh 脚本。

bin/kafka-console-consumer.sh --bootstrap-server <broker-list> --topic <topic-name> --from-beginning

在这里，--from-beginning 选项会从头开始消费消息，如果要从最新的消息开始消费则去掉此选项。