列出所有kafka主题

Question

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

Answer 1

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

Answer 2

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

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

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

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

Answer 3

命令：

启动卡夫卡：

 $ nohup ~/kafka/bin/kafka-server-start.sh ~/kafka/config/server.properties > ~/kafka/kafka.log 2>&1 &

列出 kafka 上的所有主题：

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

要检查数据是否登陆 kafka 主题并将其打印出来：

$ bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic your_topic_name --from-beginning

Answer 4

Kafka 2.2及更高版本

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

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

Answer 5

对于docker化的kafka / zookeeper

docker ps

找到您的Zookeeper容器ID

docker exec -it <id> bash

cd bin

./zkCli.sh

ls /brokers/topics

Answer 6

我们可以使用以下命令：

kafka-topics.sh --list --bootstrap-server localhost:9092

列出所有主题