kafka安裝以及使用(超簡版本)
tar -zxvf kafka_2.12-2.3.1.tgz -c /user/dreamer/software
4、注意先啟動zookeeper,進入kafka/bin目錄下,使用預設配置
sh zookeeper-server-start.sh ../config/zookeeper.properties
5、啟動kakfa,使用預設配置
sh kafka-server-start.sh ../config/server.properties
6、建立topic
sh kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic demo_topic
7、檢視當前kafka例項下所有的topic
sh kafka-topics.sh --list --zookeeper localhost:2181
8、啟動控制台生產者
sh kafka-producer-perf-test.sh --broker-list localhost:9092 --topic demo_topic
9、啟動控制台消費者
sh kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --from-beginning --topic demo_topic
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 ...