kafka部署配置執行

2021-08-20 13:26:31 字數 1157 閱讀 2173

二:修改配置檔案

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