当你使用kafka-topics.sh创建（删除）了一个topic之后，Kafka背后会执行什么逻辑？
发布于 2020-05-19 18:13:12
关注者
0
被浏览
1171
1 个回答
-
1）会在zookeeper中的/brokers/topics节点下创建一个新的topic节点，如：/brokers/topics/first
2）触发Controller的监听程序
3）kafka Controller 负责topic的创建工作，并更新metadata cache
