Tagged: kraft

0

Kafka进阶之内部Cluster架构分析

我们在前面的文章中已经介绍了Kafka的基础部分包括Producer,consumer等基本概念,本文来稍微深入聊一聊Kafka内部Cluster的架构。这个部分的理解对我们Debug相关的问题会有很大的帮助。 Cluster成员 Kafka在3. 0版本之前使用的是ZooKeeper来进行管理broker的列表的。每一个broker都用一个唯一的ID来进行标识。当一个broker启动的时候,它会去ZooKeeper中利用它的ID来创建一个ephemeral node。其它的broker包括controller可以subscribe到/brokers/ids这个路径下,这样每次有新的broker加入或者删除的时候都可以得到通知。当然如果有同样的ID试图加入,也会有error信息报出。...