Tagged: kraft

我们在前面的文章中已经介绍了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信息报出。...