操作kafka之前，要先啟動安裝好的zk ，因為kafka的資料都儲存在zk中，zk相當於是kafka的資料庫吧。

安裝的zk kafka 一定要按照書上，網上的教程，將相應的配置檔案全部改成自己的，埠號，ip地址，檔案目錄都要一一確認無誤

　在後臺啟動kafka

./kafka-server-start.sh -daemon ../config/server.properties

關閉kafka
kafka-server-stop.sh 

Kafka服務關閉失敗 No kafka server to stop

解決方法：進入kafka安裝目錄下的bin目錄，編輯kafka-server-stop.sh指令碼，修改以下內容
編輯命令：vi kafka-server-stop.sh

將PIDS=$(ps ax | grep -i ‘kafka.Kafka’ | grep java | grep -v grep | awk ‘{print $1}’)
修改為：PIDS=$(jps -lm | grep -i 'kafka.Kafka' | awk '{print $1}')

命令作用：使用jps -lm命令列出所有的java程序，然後通過管道，利用grep -i 'kafka.Kafka’命令將kafka程序篩出來，最後再接一管道命令，利用awk將程序號取出來。

建立topic 主題名為 first

./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic first

檢視建立的Topic
 


./kafka-topics.sh --list(decribe) --zookeeper localhost:2181

#啟動生產者
./kafka-console-producer.sh --broker-list localhost:9092 --topic test

再開啟一個視窗，登入，進入kafka啟動目錄，啟動消費者
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test 

在生產者視窗輸入資訊，在消費者視窗便會接受到生產者輸入的訊息