当你使用kafka-topics.sh创建（删除）了一个topic之后，Kafka背后会执行什么逻辑？
发布于 2020-05-19 18:13:18
关注者
0
被浏览
666
1 个回答
-
创建:在zk上/brokers/topics/下节点 kafkabroker会监听节点变化创建主题 删除:调用脚本删除topic会在zk上将topic设置待删除标志，kafka后台有定时的线程会扫描所有需要删除的topic进行删除
