代码之家 › 专栏 › 技术社区 › King David

你是怎么和卡夫卡交谈才知道卡夫卡已经起床的

apache-zookeeper apache-kafka

King David · 技术社区 · 6 年前

虽然kafka机器不是与zookeper服务器共同托管的(kafka在不同的机器上,操作系统是Redhat7.x版本)

cd /usr/hdp/current/zookeeper-server/bin

./zkCli.sh

ls /brokers/ids

结果应该是三个经纪人的身份证

1011  1012  1013

我的问题是-zookeper以哪种方式知道经纪人的身份?

执行哪个cli zookeper来识别kafka代理启动了?

1 回复 | 直到 6 年前

OneCricketeer Gabriele Mariotti 6 年前

Zookeeper基本上是一个分布式键值存储。启动时,Kafka代理会连接到Zookeeper(使用 zookeeper.connect 设置)并创建一个znode(一个键值对) broker.id /brokers/ids . 卡夫卡经纪人则在他们运行时与Zookeeper保持联系。

这样,Zookeeper就可以随时知道哪些代理还活着(这并不一定意味着代理是健康的!)。代理使用它来发现集群中的其他代理。

推荐文章

user2665483 · 如何使用Apache Curator监视两级以下节点的创建?

7 年前

user9467051 · 无法启动zookeeper服务器

7 年前

harpratap · Zookeeper或Marathon docker容器使用100%CPU

7 年前

enodmilvado · 从HDP当前版本2.6.0.3升级到2.6.4失败

7 年前

Dean Le · Kafka docker容器无法在虚拟机中运行

7 年前

skyde · Postgresql HA集群与Patenti的一致性如何?

7 年前

Supun Wijerathne · Zookeeper和Eureka在微服务中扮演什么角色?

7 年前

Ami Hollander · 使用凭据通过kazoo lib连接到Zookeeper

7 年前

Gabbar · SolrCloud ZooKeeper兼容性

7 年前

dhalfageme · HBase:MasterNotRunningException:节点/HBase不在zookeeper中

7 年前