Kafka單機配置部署


摘要:上節 學習了Kafka的理論知識,這里安裝單機版以便后續的測試。

首先安裝jdk

一、單機部署zk

1.1安裝:

tar -zxf zookeeper-3.4.10.tar.gz -C /opt/

1.2配置:

在主目錄下創建data用於存儲數據:
cd /opt/zookeeper-3.4.10/
mkdir data
在conf目錄下新建zoo.cfg文件,寫入以下內容保存:
tickTime=2000
dataDir=/opt/zookeeper-3.4.10/data
dataLogDir=/opt/zookeeper-3.4.10/logs
clientPort=2181

1.3啟動和停止

進入bin目錄,啟動、停止、重啟和查看當前節點狀態(包括集群中是何角色)分別執行:
./zkServer.sh start
./zkServer.sh stop
./zkServer.sh restart
./zkServer.sh status

二、單機部署kafka

2.1安裝:

tar -xvzf kafka_2.11-1.0.1.tgz -C /opt

2.2配置:

cd /opt/kafka_2.11-1.0.1/config
修改文件server.properties:
broker.id=1     # 唯一ID同一集群下broker.id不能重復
listeners=PLAINTEXT://localhost:9092   # 監聽地址
log.dirs=/opt/kafka_2.11-1.0.1/data      # 數據目錄
log.retention.hours=168   # kafka數據保留時間單位為hour 默認 168小時即 7天 
log.retention.bytes=1073741824  #(kafka數據量最大值,超出范圍自動清理,和 log.retention.hours配合使用,注意其最大值設定不可超磁盤大小)
zookeeper.connect:192.168.10.100:2181  #(zookeeper連接ip及port,多個以逗號分隔)

2.3啟動和停止:

./bin/kafka-server-start.sh config/server.propertiess
./bin/kafka-server-stop.sh

2.4創建topic

創建topic:
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
展示topic:
bin/kafka-topics.sh --list --zookeeper localhost:2181
生產者:
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
消費者:
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM