kafka1 0安裝部署

2021-08-11 13:40:08 字數 1663 閱讀 5167

kafka 1.0安裝部署

2、解壓安裝包,執行命令:tar -zxvf kafka_2.11-1.0.0.tgz

3、更改kafka broker配置:

修改config目錄下server.properties配置檔案

broker.id(同一集群下broker.id不能重複)

listeners=plaintext://ip:9092(ip為本機ip,9092埠可更改)

log.dirs=/tmp/kafka-logs(kafka資料儲存路徑,多個路徑逗號分隔即可,如:data1,data2)

log.retention.hours=168(kafka資料過期清理時間,單位為/hour)

log.retention.bytes=1073741824(kafka資料量最大值,超出範圍自動清理,和log.retention.hours配合使用,注意其最大值設定不可超高磁碟大小)

zookeeper.connect:localhost:2181(zookeeper連線ip及port,多個以逗號分隔即可)

group.initial.rebalance.delay.ms=0(group rebalance延時等待,合理設定可減少rebalance頻率,0.11.x後新增功能)

4、配置完成後執行啟動命令:./bin/kafka-server-start.sh config/server.properties(如無執行許可權可在bin目錄下執行 chmod 775 * ,然後再執行啟動命令)

後台啟動命令:nohup ./bin/kafka-server-start.sh config/server.properties >/dev/null 2>&1 &

5、將kafka拷貝到其他部署機器:

執行命令:scp -r kafka_2.11-1.0.0 ip:path (ip為需拷貝過去的遠端機器ip,path為kafka安裝路徑)

更改broker.id(同一集群下broker.id不能重複)

listeners=plaintext://ip:9092(ip為本機ip,9092埠可更改)

log.dirs=/tmp/kafka-logs(kafka資料儲存路徑,多個路徑逗號分隔即可,如:data1,data2)

配置完成後啟動即可。

6、驗證通訊:

任選一台機器執行命令:

建立topic:bin/kafka-topics.sh --create --zookeeper zkip:2181  --replication-factor 1 --partitions 1 --topic test

檢視已存在的topic:bin/kafka-topics.sh --list --zookeeper zkip: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

在生產者視窗輸入任意內容,然後按enter鍵,在消費者視窗出現相同內容即為安裝成功。

Kafka安裝部署

1 解壓安裝包 atguigu hadoop102 software tar zxvf kafka 2.11 0.11.0.0.tgz c opt module 2 修改解壓後的檔名稱 atguigu hadoop102 module mv kafka 2.11 0.11.0.0 kafka3 在 ...

kafka集群安裝部署

wget 2.tar zxvf kafka 2.12 2.1.0.tgz 解壓安裝包 3.備份kafka zookeeper配置檔案 cp server.properties server.properties.bak cp zookeeper.properties zookeeper.proper...

Kafka的安裝部署

安裝過程非常簡單,只需要解壓就行,因為這個是編譯好之後的可執行程式 因為kafka依賴於zookeeper來做master選舉一起其他資料的維護,所以需要先啟動zookeeper節點 kafka內建了zookeeper的服務,所以在bin目錄下提供了這些指令碼 zookeeper server st...