打開(kāi)Ubuntu虛擬機(jī)

進(jìn)入zookeeper安裝目錄 gb@gb-VMware-Virtual-Platform:~$ cd /usr/apache-zookeeper-3.9.3-bin

在終端啟動(dòng)zookeeper服務(wù) gb@gb-VMware-Virtual-Platform:/usr/apache-zookeeper-3.9.3-bin$ sudo bin/zkServer.sh start

檢查zookeeper進(jìn)程 gb@gb-VMware-Virtual-Platform:/usr/apache-zookeeper-3.9.3-bin$ ps -ef | grep zookeeper

進(jìn)入kafka安裝目錄 gb@gb-VMware-Virtual-Platform:/usr/apache-zookeeper-3.9.3-bin$ cd /home/gb/下載/kafka

在終端啟動(dòng)kafka服務(wù) gb@gb-VMware-Virtual-Platform:~/下載/kafka$ bin/kafka-server-start.sh config/server.properties

另起一個(gè)終端（以下在終端輸入的代碼均在新開(kāi)的終端中進(jìn)行）

檢查kafka進(jìn)程 gb@gb-VMware-Virtual-Platform:~/下載/kafka$ ps -ef | grep kafka

查看topic gb@gb-VMware-Virtual-Platform:~/下載/kafka$ bin/kafka-topics.sh --list --bootstrap-server IP address:9092

使用消費(fèi)者 gb@gb-VMware-Virtual-Platform:~/下載/kafka$ bin/kafka-console-consumer.sh --bootstrap-server IP address:9092 --topic haha --from-beginning

打開(kāi)windows中的kafka assistant

在kafka assistant中向虛擬機(jī)中發(fā)送消息，檢查終端是否收到消息

退出消費(fèi)者模式，在終端按Ctrl+C

使用生產(chǎn)者 gb@gb-VMware-Virtual-Platform:~/下載/kafka$ bin/kafka-console-producer.sh --broker-list IP address:9092 --topic haha