當前位置:編程學習大全網 - 源碼下載 - Kafka獨立部署

Kafka獨立部署

kafka的安裝需要zookeeper,但是kafka集成了zookeeper,可以直接用於單機部署。只需在Kafka _ 2.11 . x/config下配置zookeeper.preperties即可。

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,消費者終端可以接收到這個消息,這是正常的。

  • 上一篇:傳奇世界1.5版的名稱是什麽
  • 下一篇:如何在Ubuntu 11.10下安裝KScope?
  • copyright 2024編程學習大全網