我创建了 3 个 Kafka 经纪人设置,经纪人 ID 为 20、21、22。然后我创建了这个主题:
bin/kafka-topics.sh --zookeeper localhost:2181 \
--create --topic zeta --partitions 4 --replication-factor 3
Run Code Online (Sandbox Code Playgroud)
结果是:
当生产者向主题 zeta 发送消息“hello world”时,Kafka 首先将消息写入哪个分区?
“hello world”消息会在所有 4 个分区中复制吗?
3 个代理中的每个代理都包含所有 4 个分区?这与上述上下文中的复制因子 3 有何关系?
如果我有 8 个在自己的进程或线程中并行运行的消费者订阅了 zeta 主题,Kafka 如何分配分区或代理来并行服务这些消费者?