二:修改配置檔案
①:config目錄下zookeeper.properties
datadir=/tmp/zookeeper/data
datalogdir=/tmp/zookeeper
clientport:2181
maxclientcnxns=100
ticktime=2000
initlimit=10
synclimit=5
server.0=192.168.xx.***:2888:3888
server.0=192.168.xx.***:2888:3888
(server.a=b:c:d a:zookeeper的id ;b:ip位址 ;c:kafka之間通訊用的埠,需要確保埠開放且有連線 ;d:當leader掛掉通過此埠選舉leader)
注意:多台機器上zookeeper配置檔案保持一致,另外在datadir的目錄下要有乙個myid的檔案,檔案中寫id,比如這台機子是server.1,那麼在檔案中就只寫乙個 1 就ok
②:server.properties
broker.id,保證每個broker唯一,第一台可以不修改預設為0,後面兩台需要修改,如改為1和2
port=9092
host.name=***.***.xx.***(本機ip)
log.dirs=/usr/kafka
listeners=plaintext:
zookeeper.connect=***.***.***.xxa:2181,***.***.***.xxb:2181,***.***.***.xxc:2181
三:建立生產者
bin/kafka-console-producer.sh --broker-list ***.***.***.xxa
:9092,***.***.***.xxb
:9092,***.***.***.xxc
:9092 --topic topicname
四:建立消費者
bin/kafka-console-consumer.sh --zookeeper ***.***.***.xxa
:2181,***.***.***.xxa
:9092,***.***.***.xxa
:9092--from-beginning --topic topicname
ubuntu下下kafka 單機配置部署
修改配置vim etc profile export zookeeper home usr local kafka zookeeper 3.3.6 使配置生效 source etc profile 成功 sh zookeeper home bin zkserver.sh start jmx enab...
單機部署和配置Kafka集群
前言 需要說明的幾個問題 1 kafka依賴zookeeper,請先安裝zookeeper。2 zookeeper依賴j a環境,請先安裝jdk。3 zookeeper單機集群規劃 3個節點,埠號分別是2181 2812 2813。4 zookeeper單機集群關鍵在於隔離各節點的埠 資料。各個節點...
Kafka 單機kafka部署
1 上傳部署包 kafka 2.11 0.11.0.0.tgz 放到 opt software 2 解壓 tar zxvf kafka 2.11 0.11.0.0.tgz c opt module 3 切換目錄 opt module kafka 2.11 0.11.0.0 conf 4 修改配置 v...