1. 程式人生 > >kafka 在linux ubuntu下跑起來攻略(不包含解壓之類的)

kafka 在linux ubuntu下跑起來攻略(不包含解壓之類的)

kafka 跑起來 步驟
首先 剛進來的時候 測試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日誌

建立 topic
重複獲取系統許可權那一步
進入 kafka的解壓目錄 不需要進入bin目錄
輸入 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 localhost:2181
執行 成功 輸出 test
傳送訊息
輸入 bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
執行 出現 > 後面可以輸入字元為正確

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

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