0.在三台機器上配置kafka的環境
可以參考另一篇文章:https://www.cnblogs.com/codedoge/p/10100953.html
1.首先配置zookeeper集群,打開zookeeper的配置文件
vi config/zookeeper.properties
三台機器都做一模一樣的操作即可
2.分別創建myid
"server.id=host:port:port" 表示不同服務器的配置。id表示不同服務器,在服務器配置文件的dataDir所設置的目錄里需要手動創建一個叫做myid的文件,這個文件只有一行內容,標識自己的身份也就是自己的ID值,該值范圍可以是1-255之間。
echo 153 > /tmp/zookeeper/myid //153機器 echo 154 > /tmp/zookeeper/myid //154機器 echo 155 > /tmp/zookeeper/myid //155機器
3.分別啟動zookeeper
./bin/zookeeper-server-start.sh ./config/zookeeper.properties
4.接下來配置kafka集群分別修改三台機器上kafka的配置文件
vi config/server.properties
注意三台機器不可相同,配置范圍是0~255
配置zookeeper
5.分別啟動kafka
./bin/kafka-server-start.sh ./config/server.properties
6.開啟負載均衡
./bin/kafpreferred-replica-election.sh --zookeeper 10.1.3.153:2181,10.1.3.155:2181,10.1.3.154:2181
7.創建需要的topic,將備份數設置為三
bin/kafka-topics.sh --create --zookeeper zookeeperip:2181 --replication-factor 3 --partitions 1 --topic test