安裝單機版kafka及其配置
阿新 • • 發佈：2021-11-19
1.安裝
kafka安裝包可以通過官網下載：https://kafka.apache.org/downloads
本次案例使用 kafka_2.11-1.0.0.tgz，
把軟體上傳或下載到/opt/ 下目錄 2.解壓縮tar -zxvf kafka_2.11-1.0.0.tgz3.kafka配置和啟動 kafka的配置檔案在config/server.properties檔案中，主要修改引數如下，更具體的引數說明以後再整理下 記得修改為你自己的ip 3.1配置
3.2 啟動 先啟動zookeeper，方法在下面
3.2.1啟動kafka
/opt/kafka_2.11-1.0.0/bin ./kafka-server-start.sh ../config/server.properties
3.2.2 建立主題 topic
建立了一個分割槽，一個副本 主題為test
./kafka-topics.sh --create --zookeeper 192.168.224.111:2181 --partitions 1 -- replication-factor 1 --topic test
3.2.3啟動生產者
生產者指定test主題
./kafka-console-producer.sh --broker-list 192.168.224.111:9092 --topic test
3.2.4 啟動消費者
指定主題test
./kafka-console-consumer.sh --bootstrap-server 192.168.224.111:9092 --topic test4.啟動\關閉Zookeeper 4.1啟動
./bin/zookeeper-server-start.sh -daemon ./config/zookeeper.properties
4.2關閉
./bin/zookeeper-server-stop.sh -daemon ./config/zookeeper.properties目前是簡單的啟動關閉，缺的東西慢慢補上。關閉也可以使用jps檢視埠號，kill -9 埠號 殺死程序