tar -xvf卡夫卡_2.11-2.3.0.tgz
修改兩個配置項,dataDir和clientPort。前者是快照的存儲地址,後者是客戶端連接到zookeeper服務的端口。
根據自己的實際情況填寫,也可以直接用默認值。
修改兩個配置選項,log.dirs和zookeeper.connect
Log.dirs可以根據實際情況填寫,也可以直接使用默認值。
Zookeeper.connect應該與zookeeper.preperties文件中的clientPort壹致。
以上操作完成後,單機部署完成。
諾胡普。/zookeeper-server-start.sh../config/zookeeper . properties & gt;../zookeeper . log & amp;
在後臺啟動zookeeper,並將啟動日誌寫入zookeeper.log
啟動後檢查zookeeper.log,查看zookeeper是否成功啟動。
諾胡普。/kafka-server-start.sh../config/server . properties & gt;../卡夫卡. & amp
Kafkaserver在後臺啟動,啟動日誌被寫入kafka.log
啟動後檢查kafka.log,看啟動是否成功。
。/Kafka-topics . sh-create-zookeeper IP:2291-replication-factor 1-partitions 1-topic test & amp;
。/Kafka-console-producer . sh-broker-list IP:9092-topic test & amp;
。/Kafka-console-consumer . sh-bootstrap-server IP:2291-話題測試-從頭開始
檢查生產者和消費者是否正常的方法:
生產者和消費者各自打開壹個終端,並執行命令來分別創建生產者和消費者。執行生產者命令後,他們發送壹個消息:kafkatest,消費者終端可以接收到這個消息,這是正常的。