? ? ? ? 簡(jiǎn)介：下面是kafka集群的一些操作步驟阱持，由于步驟較多在這里寫(xiě)下來(lái)，一來(lái)整理一下記憶乱顾、二來(lái)以防自己遺忘后沒(méi)有熟悉的操作說(shuō)明乍钻。以下內(nèi)容都是建立在kafka集群搭建好后的基礎(chǔ)上的。
一庆寺、開(kāi)啟kafka集群
開(kāi)啟zookeeper集群(千萬(wàn)不要開(kāi)啟kafka自帶的zookeeper集群)
zkServer.sh start &
有多少臺(tái)虛擬要就要開(kāi)啟多少次蚊夫，建議在后面加& 讓集群在后臺(tái)運(yùn)行
啟動(dòng)成功后輸入jps看一下進(jìn)程
三臺(tái)虛擬機(jī)上都顯示出QuorumPeerMain然表示zookeeper啟動(dòng)成功
然后是啟動(dòng)KAFKA服務(wù)（每臺(tái)虛擬機(jī)都需要啟動(dòng)一次）
bin/kafka-server-start.sh config/server.properties &
開(kāi)啟成功后用jps看一下進(jìn)程
每臺(tái)虛擬機(jī)上都有kafka這個(gè)進(jìn)程，表示kafka啟動(dòng)成功了.
下面要做一個(gè)通信接收功能
首先創(chuàng)建 topic(ip是本機(jī)ip)
bin/kafka-topics.sh --create --zookeeper 192.168.200.11:2181 --replication-factor 2 --partitions 1 --topic elm
創(chuàng)建一個(gè)producer懦尝，發(fā)布者（ip是主機(jī)ip）
bin/kafka-console-producer.sh --broker-list 192.168.200.11:9092 --topic elm
創(chuàng)建一個(gè)consumer,?訂閱者(ip是本機(jī)ip)
bin/kafka-console-consumer.sh --bootstrap-server 192.168.200.13:9092 --topic elm --from-beginning
然后發(fā)送都發(fā)布消息知纷、訂閱者接收到消息壤圃，則證明kafka集群搭建成功?
查看topic列表
bin/kafka-topics.sh --list --zookeeper localhost:2181
