linux搭建kafka集群

tar -zxvf kafka_2.12-2.3.1.tgz

開啟環境變數配置檔案

vim /etc/profile

export kafka_home=/usr/local/programs/kafka_2.12-2.3.1

export path=$/bin:$path

source /etc/profile

#這個1就是和zookeeper的myid檔案的1對應

broker.id=1

listeners=plaintext:

advertised.listeners=plaintext:

zookeeper.connect=server1:2181,server2:2181,server3:2181

zkserver.sh start

kafka-server-start.sh -daemon /root/ff/kafka/kafka_2.12-2.3.1/config/server.properties

jps

#在leader上建立主題

kafka-topics.sh --create --zookeeper server1:2181,server2:2181,server3:2181 --replication-factor 3 --partitions 3 --topic wintertop

kafka-topics.sh --list --zookeeper server1:2181,server2:2181,server3:2181

kafka-console-producer.sh --broker-list server1:9092,server2:9092,server3:9092 --topic wintertop

kafka-console-consumer.sh --bootstrap-server server1:9092,server2:9092,server3:9092  --from-beginning --topic wintertop

linux 搭建 kafka集群

wget tar zxvf kafka 2.11 0.10.2.0.tgz mkdir kafka logs cd soft kafka kafka 2.11 0.10.2.0 config vi server.properties 修改 broker.id 0 注釋掉，每台伺服器的broker.i...

linux 下搭建kafka集群

sudo vim etc profile 在末尾附加 export path opt kafka zookeeper bin path 最後 source etc profile2.需先搭建zookeeper環境 cp zoo sample.cfg zoo.cfg 在 conf裡面 vim zoo....

kafka集群搭建

安裝zookeeper kafka自帶了zookeeper，建議還是用外部的zk集群，搭建步驟如下 準備3臺機器，假設我們叫c1 c2 c3，ip分別為ip1 ip2 ip3 將附件zookeeper 3.4.6.tar.gz分別拷貝至3臺機器 c1機器上解壓zookeeper 3.4.6.tar....