95-25-010-命令-topic 创建过程

Posted 2021-09-01 九师兄

文章目录

• 1.视界
• 1. topic 介绍
• 2.topic 如何创建
• 3. kafka-topics.sh创建 topic
• • 3.1 createTopic
  • • 3.1.1 获取broker和机架信息
    • 3.1.2 给broker分配副本信息
    • • 3.1.2.1 assignReplicasToBrokersRackUnaware
      • 3.1.2.2 assignReplicasToBrokersRackAware
    • 3.1.3 createTopicWithAssignment
• 4. Producer 创建 topic
• 5. replicas 更新到 zk 后触发的操作
• • 5.1 onNewPartitionCreat