如何在集群中列出所有可用的Kafka经纪人？
我正在写一个shell脚本来监视Kafka经纪人。
我浏览了一些链接，发现如果ZooKeeper包含一个代理列表，如果这个列表中有IP地址，那么一个kafka代理正在运行。
我想要一个命令，我可以在我的shell脚本中使用，以获得代理列表，并检查kafka是否正在运行。
是否有curl命令可以像ElasticSearch一样获取kafka集群状态？
共有1个答案
该命令将为您提供方括号中的活动代理列表：
./bin/zookeeper-shell.sh localhost:2181 ls /brokers/ids
-
我在Windows子系统Linux上安装了kafka，并开始使用命令服务启动，所有服务都已启动。现在，当我尝试从Windows运行我的kafka-spring应用程序时，它显示以下错误：- 无法建立与节点-1（localhost/127.0.0.1：9092）的连接。经纪人可能不可用。 我的服务器属性是：- 我哪里出错了？？？
-
当spring-boot应用程序运行时，如果我完全关闭代理程序（包括kafka和zookeeper)，我会在控制台中看到这个警告，持续很长时间。 [org.springframework.kafka.kafkalistenerendpointcontainer#0-0-c-1]警告o.apache.kafka.clients.networkclient-[Consumer clientid=con
-
我计划部署Kafka集群。我有以下查询： 1)为了保护生产者和消费者与Kafka broker的通信，可以使用SSL。如果我有一个由9个代理和3个zookeeper节点组成的集群，并且如果我不想使用自签名证书，我是否必须为每个节点购买一个证书(9个3证书，成本太高)？ 正如我所读到的，生产者/消费者直接联系其中一个经纪人节点，而不联系动物园管理员。 谢谢， 病毒的
-
这就是我如何开始我的3个Kafka节点： 动物园管理员和Kafka集群在独立测试时表现良好。 我的意思是，我可以连接到一个Zookeeper节点（比如zoo1)，并创建一个zNode。我可以在之后停止节点（例如，docker停止zoo1)，并且我仍然可以从Zookeeper集群中的任何其他节点查询znode。 我将收到一个未知的HostException： 但是，我确实需要Kafka集群能够充分发
-
对于那些使用过亚马逊MSK（Kafka的托管流媒体）的人来说，一个快速的问题： Docs/FAQ清楚地表明，您可以轻松地扩大MSK集群中代理的数量。你能同样容易地把数字缩回吗？我说的不是自动缩放，而是手动缩放。
-
我有两个< code>kafka 0.10.1的代理集群，之前在我的开发服务器上正确运行< code>zookeeper 3.3.6。 我最近尝试将broker版本升级到最新的，但没有开始。配置没有太大变化 谁能告诉我可能会出什么问题吗。为什么经纪人没有起步？ 已更改服务器。代理服务器1上的属性 已更改代理服务器2上的server.properties 注意： 1.Zookeeper正在两台服务器