列出所有kafka主题

我正在使用没有zookeeper的kafka 0.10.我想获得kafka主题列表.由于我们没有使用zookeeper,因此该命令无效: .如果没有zookeeper,我如何获得相同的输出？bin/kafka-topics.sh --list --zookeeper localhost:2181

Kafka使用ZooKeeper,因此如果您还没有ZooKeeper服务器,则需要先启动它.

如果您不想安装并拥有单独的zookeeper服务器,则可以使用与kafka一起打包的便捷脚本来获取快速且脏的单节点ZooKeeper实例.

启动单节点Zookeeper实例:

bin/zookeeper-server-start.sh config/zookeeper.properties

启动Kafka服务器:

bin/kafka-server-start.sh config/server.properties

列出Kafka中可用的主题:

bin/kafka-topics.sh --list --zookeeper localhost:2181

如果我们运行list topic命令,请查看该主题:

$ bin/kafka-topics.sh --list --zookeeper localhost:2181

要检查数据是否在Kafka中登陆:

$ bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic twitterstream --from-beginning

Kafka 2.2及更高版本

较新版本的Kafka不再需要ZooKeeper连接字符串来列出主题，而是可以直接通过Kafka代理访问。下载Kafka时kafka-topics.sh，该bin/文件夹中会提供。要列出主题，请执行以下操作：

bin/kafka-topics.sh --list --bootstrap-server 

对于docker化的kafka / zookeeper

docker ps

找到您的Zookeeper容器ID

docker exec -it  bash

cd bin

./zkCli.sh

ls /brokers/topics