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...