1 . 啟動zookeeper
# zkserver.sh start
2 . 配置多個broker
1. 在kafka安裝目錄的config目錄下拷貝 server.properties 分別為server-1.properties,server-2.properties,server-3 .properties
2. 在對應檔案修改預設日誌輸出路徑,監聽埠,和broker.id ,broker.id 必須互不相同.以下為參考
3 . 分別啟動多個broker
# kafka-server-start.sh -daemon $kafka_home/config/server-1.properties
# kafka-server-start.sh -daemon $kafka_home/config/server-2.properties
# kafka-server-start.sh -daemon $kafka_home/config/server-3.properties
4 . 建立topic
# kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 1 --topic my-replicated-topic
5 . 建立生產者
# kafka-console-producer.sh --broker-list localhost:9093,localhost:9094,localhost:9095 --topic my-replicated-topic
6 . 建立消費者
# kafka-console-consumer.sh --zookeeper localhost:2181 --topic my-replicated-topic
Kafka單節點多Broker部署
安裝好zookeeper並啟動服務 broker的編號,必須是唯一的,相當於主鍵 broker.id 0 每個broker監聽的埠 listeners plaintext 9090 日誌目錄,預設目錄在tmp下面,重啟後就會被清空,所以要重新指定乙個目錄 log.dirs root kafka tm...
kafka單節點多broker部署及使用
kafka單節點多broker部署及使用 將配置檔案server.properties複製三份 cp server.properties server 1.properties 更新配置檔案 server 1.properties 中引數 broker.id 1 listeners plaintex...
kafka集群部署,多節點多broker
主機名 ip 位址 安裝路徑 系統135.36.247.91 135.36.247.91 board opt kafka 2.11 1.0.0 centos linux release 7.3.1611 core 135.36.247.92 135.36.247.92 135.36.247.93 1...