1. 操作命令

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 3 --topic test

2. 原理

topic创建主要分为两个部分:命令行部分+后台(controller)逻辑部分,如下图所示。

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

Kafka 0.8 如何创建topic

leader选举:简单来说就是选取副本集合中的第一个副本作为leader副本,并把整个副本集合作为ISR。

相关文章:

  • 2021-10-14
  • 2021-07-31
  • 2021-05-07
  • 2022-01-10
  • 2021-05-21
  • 2017-11-23
  • 2022-01-08
猜你喜欢
  • 2021-10-16
  • 2021-12-13
  • 2021-11-30
  • 2021-11-02
  • 2022-12-23
  • 2021-08-28
  • 2021-06-17
相关资源
相似解决方案