我已开始学习Kafka,在学习过程中遇到了一些与Kafka工作流程相关的疑惑,我将分享这些疑惑并期望得到解答。
(1.) 创建了3个副本因子(replication-factor)和3个分区(partitions)的经纪人(broker)
当我将消息推送(push)到经纪人时,消息将被一个经纪人(leader partitions)接收并发送到其副本(replicas)中的其中一个。
传递带有副本的消息使用哪种方法?(方法1、方法2或其他方式)
- 方法1
(2.) 如果我创建一个具有3个分区(partitions)的经纪人(broker)
那么消息将由领导者分区(leader partition)接收并归属于该领导者,那其他2个分区的用途是什么?