Kafka探究之路-命令小結
操作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
在生產者窗口輸入資訊，在消費者窗口便會接受到生產者輸入的消息
