第4章中級(jí)-4.8實(shí)戰(zhàn)案例kafka集群部署

第4

使用oKer集群搭建的3個(gè)節(jié)點(diǎn)來(lái)構(gòu)建ak集群，因?yàn)镵fkaoeperkaa_2.11gz

1.Kafka提供的kafka_2.11-1.1.1.tgz軟件包，上傳至3個(gè)節(jié)點(diǎn)的 下，并執(zhí)行解壓操作，3個(gè)節(jié)執(zhí)行的解壓命##tar-zxvfkafka_2.11-修改3 listeners=PLAINTEXT://3:9092listeners=PLAINTEXT://3:9092listeners=PLAINTEXT://2:9092listeners=PLAINTEXT://2:9092listeners=PLAINTEXT://1:9092命令解析broker.id：每臺(tái)機(jī)器不能一zookeeper.connect：因?yàn)橛?臺(tái)ZooKeeper服務(wù)器，所以在這里zookeeper.connect設(shè)置為臺(tái)listeners：在配置集群的時(shí)候，必須設(shè)置，不然以后的操作會(huì)報(bào)找不到leader的錯(cuò)誤另外兩臺(tái)服務(wù)器，zookeeper.connect的配置跟這里的一樣，但是broker.id和listeners不能一 [root@zookeeper1[root@zookeeper1bin]#./kafka-server-start.sh-daemon../config/perties[root@zookeeper1bin]#jps114161146410479[root@zookeeper2bin]#[root@zookeeper2bin]#./kafka-server-start.sh-daemon../config/perties[root@zookeeper2bin]#jps111211118810175[root@zookeeper3[root@zookeeper3bin]#./kafka-server-start.sh-daemon../config/perties[root@zookeeper3bin]#jps110801018811149在zookeeper1節(jié)點(diǎn)，進(jìn)入kafka_2.11- 下，創(chuàng)建topic命令如下zookeeper1節(jié)點(diǎn)[root@zookeeper1[root@zookeeper1bin]#./kafka-topics.sh--create--zookeeper--replication-factor--replication-factor1--partitions1--topicCreatedtopic如果成功的話，會(huì)輸出“Createdtopic"test查topc，雖然topc是在3機(jī)上也看到。如在意啟動(dòng)的機(jī)kaka_2.11/b的 ：zookeeper2節(jié)點(diǎn)zookeeper3節(jié)點(diǎn)[root@zookeepe