首先 剛進來的時候 測試Java的環境是否 正常執行
輸入 Java -version
如果 正常就進行下一步 
進入系統許可權
輸入 sudo -i 回車然後 $變為#即為成功 然後下一步
進入 你kafka解壓的目錄 不需要 進入bin目錄
輸入 bin/zookeeper-server-start.sh config/zookeeper.properties 執行成功會輸出大量 沒error 日誌

新開一個視窗
重複獲取系統許可權那一步
進入 kafka的解壓目錄 進入bin目錄
輸入 ./kafka-server-start.sh ../config/server.properties 回車執行成功會輸出大量無error日誌
centos 環境下 輸入為bin/kafka-server-start.sh config/server.properties 成功同樣會輸出大量無error日誌

建立 topic
重複獲取系統許可權那一步
進入 kafka的解壓目錄 不需要進入bin目錄
輸入 bin/kafka-topics.sh --create --zookeeper 118.24.167.203:2181 --replication-factor 1 --partitions 1 --topic test
測試的時候跑的本地環境為 bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
執行 成功 輸出 Created topic "test" 
檢視 剛才建立的 topic 
輸入 bin/kafka-topics.sh --list --zookeeper 118.24.167.203:2181
執行 成功 輸出 test
傳送訊息
輸入 bin/kafka-console-producer.sh --broker-list 118.24.167.203:9092 --topic test
測試的時候跑的本地環境為 bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
執行 出現 > 後面可以輸入字元為正確

建立 消費者
重複獲取系統許可權那一步
進入 kafka的解壓目錄 不需要進入bin目錄
輸入 進入 kafka的解壓目錄 不需要進入bin目錄
bin/kafka-console-consumer.sh --bootstrap-server 118.24.167.203:9092 --topic test --from-beginning
測試的時候跑的本地環境為 bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
下面無游標 為正常

在 建立了 topic的頁面
輸入字元位置 輸入字元 回車然後在消費者頁面可以看到 topic輸出的字元 即為成功

關於Java端呼叫失敗問題
1.當一直連線錯誤的時候 有可能是安裝路徑下的server.properties 配置檔案中的 localhost沒有配置
需要配置以後 才能遠端連線其他伺服器的kafka
2.當使用消費者獲取資料的時候 一直報錯為空指標 這個問題可能是 kafka的版本和你jar包的版本不匹配 這個時候 降低你
kafka連線工具的版本即可我當前使用的是0.8.1.1版本