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

Kafka是一个分布式流处理平台，广泛应用于实时数据处理和消息队列。在Kafka中，数据被组织成多个Topic，并且可以通过Producer和Consumer进行数据生产和消费。本文将介绍如何使用Kafka命令行工具查看Topic列表、消息消费情况以及模拟生产者消费者。
查看Topic列表
要查看Kafka中的所有Topic，可以使用以下命令：
./kafka-topics.sh —zookeeper :<端口号> —list
例如，如果Zookeeper的地址是192.168.40.148，端口号是2181，则可以使用以下命令查看所有Topic：
./kafka-topics.sh —zookeeper 192.168.40.148:2181 —list
查看指定Topic的详情
要查看指定Topic的详细信息，可以使用以下命令：
./kafka-topics.sh —zookeeper :<端口号> —topic —describe
例如，要查看名为“xdoctor”的Topic的详细信息，可以使用以下命令：
./kafka-topics.sh —zookeeper 192.168.40.148:2181 —topic xdoctor —describe
查看消费者Consumer的Group列表
要查看Kafka中所有的Consumer Group列表，可以使用以下命令：
./kafka-consumer-groups.sh —bootstrap-server :<端口号> —list
例如，如果Kafka的地址是192.168.40.148，端口号是9092，则可以使用以下命令查看所有Consumer Group列表：
./kafka-consumer-groups.sh —bootstrap-server 192.168.40.148:9092 —list
模拟生产者消费者
要模拟生产者消费者，可以使用Kafka提供的Console Producer和Console Consumer工具。以下是使用这些工具的基本步骤：
生产者（Console Producer）：
./kafka-console-producer.sh —broker-list :<端口号> —topic
例如，要将消息发送到名为“test”的Topic，可以使用以下命令：
./kafka-console-producer.sh —broker-list 192.168.40.148:9092 —topic test
消费者（Console Consumer）：
./kafka-console-consumer.sh —bootstrap-server :<端口号> —topic
例如，要从名为“test”的Topic中消费消息，可以使用以下命令：
./kafka-console-consumer.sh —bootstrap-server 192.168.40.148:9092 —topic test
以上是使用Kafka命令行工具查看Topic列表、消息消费情况以及模拟生产者消费者的基本步骤。通过这些工具，您可以方便地管理Kafka集群和监控其运行状态。