? ? ? ? 簡(jiǎn)介：下面是kafka集群的一些操作步驟，由于步驟較多在這里寫下來，一來整理一下記憶、二來以防自己遺忘后沒有熟悉的操作說明。以下內(nèi)容都是建立在kafka集群搭建好后的基礎(chǔ)上的。

一、開啟kafka集群

開啟zookeeper集群(千萬不要開啟kafka自帶的zookeeper集群)

zkServer.sh start &

有多少臺(tá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 &

開啟成功后用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