在实现Kafka生产者或消费者时(例如,使用Spring),我们需要配置的一个属性是“bootstrap.servers”。
1. 概述
本文将介绍这个设置的含义及其用途。
2. Kafka拓扑结构
Kafka的拓扑结构设计用于可扩展性和高可用性。这就是为什么有一个服务器集群(代理)处理代理之间复制的主题分区。每个分区有一个代理作为领导者,其他代理作为跟随者。
生产者将消息发送到分区领导者,然后该领导者将记录传播到每个副本。消费者通常也连接到分区领导者,因为消费消息是状态变化的(消费者偏移量)。
副本的数量是复制因子。推荐值为3,因为它在性能和容错性之间提供了正确的平衡,并且云服务提供商通常提供三个数据中心(可用区)作为区域的一部分进行部署。
大约 4 分钟