三台服务器分别是192.168.10.150192.168.10.151192.168.10.152然后在三台服务器分别安装 kafka。下载 kafkawget --no-check-certificate https://dlcdn.apache.org/kafka/3.1.0/kafka_2.13-3.1.0.tgz解压tar -xzf kafka_2.13-3.1.0.tgz修改配置vim

一、Kafka 简介Kafka 是 linkedin 使用 Scala 编写具有高水平扩展和高吞吐量的分布式消息系统。Kafka 对消息保存时根据 Topic 进行归类，发送消息者成为 Producer ，消息接受者成为 Consumer ，此外 kafka 集群有多个 kafka 实例组成，每个实例(server)称为 broker。无论是 Kafka集群，还是 producer 和 consu

副本的协同机制请移步：kafka 消息分发机制、分区和副本机制（三、分区的副本机制）副本还有一个重要的机制，就是数据同步过程，它需要解决怎么传播消息在向消息发送端返回 ack 之前需要保证多少个 Replica 已经接收到这个消息一、 副本的结构深红色部分表示 test_replica 分区的 leader 副本，另外两个节点上浅色部分表示 follower 副本二、 数据的处理过程Produce

一、Java 中使用 kafka 进行通信依赖<dependency><groupId>org.apache.kafka</groupId><artifactId>kafka-clients</artifactId><version>2.0.0</version></dependency>发送端代码pu

"和"

本次搭建集群，Zookeeper节点个数（奇数）为3个。默认对外提供服务的端口号2181 ，集群内部3个节点之间通信默认使用 2888:3888。节点 IP 如下（虚拟机）：192.168.10.150192.168.10.151192.168.10.152然后在三台服务器分别安装zookeeper进入安装位置cd /usr/local/soft/zookeeper下载 zookeeperwget

一、消息分发机制1.1 kafka 消息分发策略消息是 kafka 中最基本的数据单元，在 kafka 中，一条消息由key、value两部分构成，在发送一条消息 时，我们可以指定这个key，那么 producer 会根据 key 和partition 机制来判断当前这条消息应该发送并 存储到哪个 partition 中。我们可以根据需要进行扩展 producer 的 partition 机制。代