代码之家 › 专栏 › 技术社区 › 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就可以随时知道哪些代理还活着(这并不一定意味着代理是健康的!)。代理使用它来发现集群中的其他代理。

推荐文章

yershalom · 同一消费群体中具有不同分区数量的不同卡夫卡主题

2 年前

Oskars Apinis · 将kafka从服务器迁移到docker容器

2 年前

Sravan Kumar · Apache kafka模式注册表问题

3 年前

Panadol Chong · 无法建立到节点1(localhost/127.0.0.1:9092)的连接。经纪人可能不在。甚至传入正确的端点[重复]

3 年前

MrSham · 如何确保旧版本0.10.0在卡夫卡中只处理一次

3 年前

TheTags · Kafka-PLC4X-Modbus/TCP-作业刮取期间异常

3 年前

Iheb Mar · 卡夫卡制作人/消费者粉碎每一秒的API调用

3 年前

hasherBaba · 在为Nifi编写流媒体服务时,如何解决Java的空指针异常?[闭门]

6 年前

phaigeim · 为storm consumer检查卡夫卡主题的偏移量

6 年前

Raman · Kafka流:POJO序列化/反序列化

6 年前