kafka自动创建topic如何设置

 时间:2024-10-13 03:23:37

1、Kafka创建topic命令很简单,一条命令足矣:bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-f锾攒揉敫actor 3 --partitions 3 --topic test 。

kafka自动创建topic如何设置

2、这条命令会创建一个名为test的topic,有3个分区,每个分区需分配3个副本。

kafka自动创建topic如何设置

3、topic创建主要分为两个部分:命令行部分+后台(controller)逻辑部分。

kafka自动创建topic如何设置

4、主要的思想就是后台逻辑会监听zookeeper下对应的目录节点,一旦发起topic创建命令,该命令会创建新的数据节点从而触发后台的创建逻辑。

kafka自动创建topic如何设置

5、确定分区副本的分配方案(就是每个分区的副本都分配到哪些broker上);创建zookeeper节点,把这个方案写入/brokers/topics/<topic>节点下。

kafka自动创建topic如何设置

6、Kafka controller部分主要做下面这些事情:1. 创建分区;2. 创建副本;3. 为每个分区选举leader、ISR;4.更新各种缓存。

kafka自动创建topic如何设置
  • 集体土地证的房子拆迁怎么办
  • 腾讯地图怎么点亮去过的地方
  • 苹果13如何截长图
  • 苹果如何录屏?怎么录制屏幕?
  • 美国创造学家奥斯本首创的一种决策方法
  • 热门搜索
    怎么选车 辽宁大学怎么样 水泥地面起砂怎么办 电脑广告太多怎么办 随申码怎么申请 小孩肚子疼怎么办 黑龙江科技大学怎么样 蚝油怎么用 qq怎么打空白名字 开花店怎么样