列出所有kafka主题

作者: 氷寒
发布时间: 2024-03-18 10:50:53 (1月前)
转自：

9 条回复

0#
回复此人
VIP | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> Kafka需要zookeeper，实际上主题列表存储在那里，因此kafka-topics工具也需要连接到zookeeper。新版本中的kafka-clients apis不再与zookeeper交谈 <EM> 直 </EM> ，也许这就是为什么你的印象是没有动物园管理员的设置是可能的。的<strong> 它不是 </强> ，因为卡夫卡在内部依赖它。供参考： <a href="http://kafka.apache.org/documentation.html#quickstart" rel="nofollow noreferrer"> http://kafka.apache.org/documentation.html#quickstart </A> 第2步： </p> <BLOCKQUOTE> <P> Kafka使用ZooKeeper，因此如果您还没有ZooKeeper服务器，则需要先启动它 </p> </BLOCKQUOTE> </DIV>

编辑
1#
回复此人
polo | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 运行Kafka需要Zookeeper。 zookeeper是必须的。如果你想看看没有zookeeper的主题列表，那么你需要kafka监控工具，如Kafka Monitor Tool，kafka-manager等。 </p> </DIV>

编辑
2#
回复此人
Colin | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 对于dockerized kafka / zookeeper </p> <pre> <code> docker ps </code> </pre> <P> 找到你的zookeeper容器ID </p> <pre> <code> docker exec -it <id> bash cd bin ./zkCli.sh ls /brokers/topics </code> </pre> </DIV>

编辑
3#
回复此人
青阳 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> Kafka客户不再需要zookeeper，但Kafka服务器确实需要它来运行。 </p> <P> 您可以使用新的AdminClient API获取主题列表，但尚未重写使用Kafka的shell命令以使用此新API。 </p> <P> 在没有Zookeeper的情况下使用Kafka的另一种方法是使用SaaS Kafka即服务提供商，例如Confluent Cloud，这样您就不会看到或操作Kafka代理（以及所需的后端Zookeeper集合）。 </p> <P> 例如，在Confluent Cloud上，您只需使用以下zookeeper free CLI命令： </p> <pre> <code> ccloud topic list </code> </pre> </DIV>

编辑
4#
回复此人
尼拉。 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 要阅读消息，您应该使用： </p> <pre> <code> kafka-console-consumer.sh --bootstrap-server kafka1:9092,kafka2:9092,kafka3:9092 --topic messages --from-beginning </code> </pre> <P> <code> --bootstrap-server </code> 是必需属性。你只能使用单身 <code> kafka1:9020 </code> 节点。 </p> </DIV>

编辑
5#
回复此人
⑩Ⅵ嵗Ｄ夨憶 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> Kafka是一个分布式系统，需要Zookeeper。你也要开始管理动物园。点击此处的“快速入门”： <a href="https://kafka.apache.org/0100/documentation.html#quickstart" rel="nofollow noreferrer"> https://kafka.apache.org/0100/documentation.html#quickstart </A> </p> </DIV>

编辑
6#
回复此人
梦中会飞的鱼 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> Kafka使用ZooKeeper，因此如果您还没有ZooKeeper服务器，则需要先启动它。 </p> <P> 如果您不想安装并拥有单独的zookeeper服务器，则可以使用与kafka一起打包的便捷脚本来获取快速且脏的单节点ZooKeeper实例。 </p> <P> 的<strong> 启动单节点Zookeeper实例： </强> </p> <pre> <code> bin/zookeeper-server-start.sh config/zookeeper.properties </code> </pre> <P> 的<strong> 启动Kafka服务器： </强> </p> <pre> <code> bin/kafka-server-start.sh config/server.properties </code> </pre> <P> 的<strong> 列出Kafka中可用的主题： </强> </p> <pre> <code> bin/kafka-topics.sh --list --zookeeper localhost:2181 </code> </pre> </DIV>

编辑
7#
回复此人
LOGO | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 如果我们运行list topic命令，请查看该主题： </p> <P> <code> $ bin/kafka-topics.sh --list --zookeeper localhost:2181 </code> </p> <P> 要检查数据是否在Kafka中登陆： </p> <P> <code> $ bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic twitterstream --from-beginning </code> </p> </DIV>

编辑

登录后才能参与评论