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

Kafka是一个分布式流处理平台，用于构建实时数据流管道和应用。它提供了高吞吐量、低延迟的发布和订阅消息传递服务。在Kafka中，消息被存储在称为Topic的类别中，多个消费者可以订阅同一个Topic来消费其中的消息。
一、查看Topic列表
要查看Kafka中的所有Topic，可以使用Kafka提供的命令行工具kafka-topics.sh结合--list参数。具体命令如下：

./kafka-topics.sh --zookeeper <Zookeeper地址>:<端口号> --list

将<Zookeeper地址>和<端口号>替换为你的Kafka集群中的Zookeeper地址和端口号。执行该命令后，将会列出所有Topic的名称。
二、查看消费者消费情况
要查看消费者的消费情况，可以使用Kafka提供的命令行工具kafka-consumer-groups.sh结合--list参数。具体命令如下：

./kafka-consumer-groups.sh --bootstrap-server <Kafka服务器地址>:<端口号> --list

将<Kafka服务器地址>和<端口号>替换为你的Kafka服务器地址和端口号。执行该命令后，将会列出所有消费者的组名。
如果你想查看指定消费者的组消费情况，可以使用--describe参数，并指定组名。具体命令如下：

./kafka-consumer-groups.sh --bootstrap-server <Kafka服务器地址>:<端口号> --group <组名> --describe

将<Kafka服务器地址>、<端口号>和<组名>替换为相应的值。执行该命令后，将会显示指定消费者的组消费情况，包括每个Topic的消费进度、消费者的偏移量等信息。
三、模拟生产者和消费者
要模拟Kafka的生产者和消费者，可以使用Kafka提供的命令行工具kafka-console-producer.sh和kafka-console-consumer.sh。

1. 模拟生产者：使用kafka-console-producer.sh工具发送消息到指定的Topic。具体命令如下：

   ./kafka-console-producer.sh --broker-list <Kafka服务器地址>:<端口号> --topic <Topic名称>

   将<Kafka服务器地址>、<端口号>和<Topic名称>替换为相应的值。执行该命令后，将会在终端中输入要发送的消息，输入完毕后按Ctrl+D结束发送。发送的消息将会被发送到指定的Topic中。
2. 模拟消费者：使用kafka-console-consumer.sh工具消费指定Topic的消息。具体命令如下：

   ./kafka-console-consumer.sh --bootstrap-server <Kafka服务器地址>:<端口号> --topic <Topic名称> --from-beginning

   将<Kafka服务器地址>、<端口号>和<Topic名称>替换为相应的值。执行该命令后，将会从指定的Topic中消费消息，并输出到终端中。使用--from-beginning参数可以从头开始消费消息。
   通过以上介绍，你可以方便地查看Kafka中的Topic列表、查看消费者消费情况以及模拟生产者和消费者。在实际使用中，可以根据自己的需求选择合适的工具和参数进行操作。