对于dockerized kafka / zookeeper
docker ps
找到你的zookeeper容器ID
docker exec -it <id> bash cd bin ./zkCli.sh ls /brokers/topics
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
Kafka客户不再需要zookeeper,但Kafka服务器确实需要它来运行。
您可以使用新的AdminClient API获取主题列表,但尚未重写使用Kafka的shell命令以使用此新API。
在没有Zookeeper的情况下使用Kafka的另一种方法是使用SaaS Kafka即服务提供商,例如Confluent Cloud,这样您就不会看到或操作Kafka代理(以及所需的后端Zookeeper集合)。
例如,在Confluent Cloud上,您只需使用以下zookeeper free CLI命令:
ccloud topic list
Kafka需要zookeeper,实际上主题列表存储在那里,因此kafka-topics工具也需要连接到zookeeper。 新版本中的kafka-clients apis不再与zookeeper交谈 直 ,也许这就是为什么你的印象是没有动物园管理员的设置是可能的。 的 它不是 强> ,因为卡夫卡在内部依赖它。供参考: http://kafka.apache.org/documentation.html#quickstart 第2步:
Kafka使用ZooKeeper,因此如果您还没有ZooKeeper服务器,则需要先启动它
如果我们运行list topic命令,请查看该主题:
$ bin/kafka-topics.sh --list --zookeeper localhost:2181
要检查数据是否在Kafka中登陆:
$ bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic twitterstream --from-beginning
Kafka是一个分布式系统,需要Zookeeper。 你也要开始管理动物园。 点击此处的“快速入门”: https://kafka.apache.org/0100/documentation.html#quickstart
运行Kafka需要Zookeeper。 zookeeper是必须的。如果你想看看没有zookeeper的主题列表,那么你需要kafka监控工具,如Kafka Monitor Tool,kafka-manager等。
要阅读消息,您应该使用:
kafka-console-consumer.sh --bootstrap-server kafka1:9092,kafka2:9092,kafka3:9092 --topic messages --from-beginning
--bootstrap-server 是必需属性。 你只能使用单身 kafka1:9020 节点。
--bootstrap-server
kafka1:9020