Kafka的console工具主要包括kafka-topics.sh
(用于列出主题)、kafka-console-consumer.sh
(用于消费消息)和kafka-console-producer.sh
(用于生产消息)。其中,kafka-topics.sh
脚本可以用来查看Kafka集群中的所有主题。
要查看所有主题,请在Kafka的bin目录下运行以下命令:
./kafka-topics.sh --list --zookeeper <zookeeper_host:port>
其中,<zookeeper_host:port>
是Kafka集群中Zookeeper服务的地址和端口。例如,如果你的Zookeeper服务运行在本地的9092端口上,那么命令应该是:
./kafka-topics.sh --list --zookeeper localhost:9092
执行此命令后,你将看到Kafka集群中所有主题的列表。