kafka安裝配置詳解

2021-09-26 13:50:16 字數 823 閱讀 5262

1.啟動zookeeper,jps---> quorumpeermain即啟動成功, 詳見

2.download kafka from

3.將壓縮檔案上傳至server目錄,解壓;

4.進入kafka目錄,執行./bin/kafka-server-start.sh config/server.properties即可啟動;

5../bin/kafka-topics.sh --list --zookeeper localhost:2181檢視topic

6./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test建立topic

7../bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test檢視topic

8../bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test 執行後傳送訊息

9../bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning執行後接收producer傳送的訊息

10.可以進入到/tmp/kafka-logs驗證segment

注:log.dirs=/tmp/kafka-logs,zookeeper.connect=localhost:2181,配置均位於config目錄下server.properties;

Kafka安裝配置

kafka執行依賴 zookeeper,如未安裝zookeeper請參考 zookeeper安裝使用 kafka版本問題 這又是一大坑 如果你的storm安裝的是1.0.x系列或更低的版本,建議你安裝0.8.x.x版本的kafka。如果你的storm安裝的是1.1.x系列或更高的版本,建議你安裝0....

kafka安裝配置

一.zookeeper部署 tar xvf zookeeper 3.4.6.tar.gz mv zookeeper 3.4.6 zookeeper chown r root root zookeeper 2.修改配置 cd zookeeper conf cp zoo sample.cfg zoo.c...

kafka安裝配置

1 部署規劃 作業系統 centos 7.2 kafka版本 kafka 2.10 0.8.2.1 安裝路徑 opt kafka 2.10 0.8.2.1 節點 192.168.20.100 105 2 部署過程 2.2 解壓 tar zxvf kafka 2.10 0.8.2.1.tgz 2.3 ...