开发者社区 问答 正文

当使用kafka-topics.sh创建(删除)了一个topic之后,Kafka背后会执行什么逻辑?

当使用kafka-topics.sh创建(删除)了一个topic之后,Kafka背后会执行什么逻辑?

展开
收起
芯在这 2021-12-12 10:18:26 548 分享 版权
1 条回答
写回答
取消 提交回答
  • 创建:在zk上/brokers/topics/下节点 kafkabroker会监听节点变化创建主题

    删除:调用脚本删除topic会在zk上将topic设置待删除标志,kafka后台有定时的线程会扫描所有需要删除的topic进行删除

    2021-12-12 10:18:40
    赞同 展开评论