摘要:上節 學習了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