本次搭建集群，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 机制。代