ubuntu下安裝kafka
阿新 • • 發佈:2018-12-12
相關環境:
ubuntu版本:16.04
kafka版本:kafka_2.11-0.11.0.0
1、安裝步驟
1、將解壓後的kafka資料夾複製到/usr/local下面
2、進入到/usr/local/kafka/conf
cd /usr/local/kafka/conf
3、更改配置檔案
vim server.properties
1、以下是是開啟遠端客戶端訪問kafka
2、修改與zookeeper伺服器之間的配置資訊,主要是埠號(預設是2180,我自己修改成了9999)
4、啟動kafka(前提是啟動了zookeeper伺服器 zkServer.sh start zoo.cfg)
以下命令需要進入到/usr/local/kafka/目錄下執行
1、啟動kafka
bin/kafka-server-start.sh config/server.properties
2、建立一個主題test
bin/kafka-topics.sh --create --zookeeper localhost:9999 --replication-factor 1 --partitions 1 --topic test
3、開啟一個生產者,併發送資料
bin/kafka-console-producer.sh --broker-list 132.232.28.164:9092 --topic test
4、開啟一個消費者
bin/kafka-console-consumer.sh --zookeeper 132.232.28.164:9999 --topic test
配置完成,可以通過客戶端程式進行測試!