Kafka 2 0 0安裝步驟及集群

2021-10-13 17:58:44 字數 2294 閱讀 8657

首先確認安裝jdk8及以上版本,

確認已安裝zookeeper,zookeeper-3.4.12安裝步驟

選擇 kafka_2.11-2.0.0.tgz版本,複製到安裝目錄,解壓縮

第二步:修改配置檔案

# borker的編號,如果集群中有多個,則每個borker需設定不同的編號

broker.id=0

#broker對外提供服務入口的埠(預設9092)

listeners=plaintext:/

/:9092

#存放訊息日誌檔案位址

log.dirs=/

data

/home/quyanhang/study/kafka/kafkadata/kafka-logs

# kafka所需zookeeper集群位址

zookeeper.connect=localhost:2181

第三步:啟動

在kafka安裝目錄下執行啟動命令

bin/kafka-server-

start

.sh config/server.properties

啟動成功:

如果後台啟動,則在啟動命令加 -daemon或者&

.

/bin/kafka-server-

start

.sh config/server.properties &或者.

/bin/kafka-server-

start

.sh -daemon config/server.properties

通過jps檢視kafka是否啟動

將解壓後的安裝包複製到不同哦個目錄,修改配置檔案

kafka-1節點配置檔案

# borker的編號,如果集群中有多個,則每個borker需設定不同的編號

broker.id=1

#broker對外提供服務入口的埠(預設9092)

listeners=plaintext:/

/:19092

#存放訊息日誌檔案位址

log.dirs=/

data

/home/quyanhang/study/kafka/kafkadata-1/kafka-logs

# kafka所需zookeeper集群位址

zookeeper.connect=localhost:21810,localhost:21811,localhost:21812

kafka-2節點配置檔案

# borker的編號,如果集群中有多個,則每個borker需設定不同的編號

broker.id=2

#broker對外提供服務入口的埠(預設9092)

listeners=plaintext:/

/:29092

#存放訊息日誌檔案位址

log.dirs=/

data

/home/quyanhang/study/kafka/kafkadata-2/kafka-logs

# kafka所需zookeeper集群位址

zookeeper.connect=localhost:21810,localhost:21811,localhost:21812

kafka-3節點配置檔案

# borker的編號,如果集群中有多個,則每個borker需設定不同的編號

broker.id=3

#broker對外提供服務入口的埠(預設9092)

listeners=plaintext:/

/:39092

#存放訊息日誌檔案位址

log.dirs=/

data

/home/quyanhang/study/kafka/kafkadata-3/kafka-logs

# kafka所需zookeeper集群位址

zookeeper.connect=localhost:21810,localhost:21811,localhost:21812

分別啟動三個節點,啟動成功後可用指令碼進行驗證

kafka指令碼收發訊息

kafka集群搭建步驟

1 搭建軟體環境 1 linux一台或多台,大於等於2 2 已經搭建好的zookeeper集群 2 解壓tar zxvf kafka 2.10 0.10.1.1.tgz 3 在kafka安裝目錄下,新建目錄kafkalogs 4 在config目錄下修改配置檔案server.properties,b...

安裝kafka 集群

wget org kafka 1.0 0 kafka 2.11 1.0 0.tgz tar zxvf kafka 2.11 1.0 0.tgz vi kafka 2.11 1.0 0 config server.properties主要修改的有如下 log.dirs home data kafka ...

kafka集群安裝

請參考上一章zookeepe集群安裝 wget org kafka 0.9 0.1 kafka 2.11 0.9 0.1 tgz tar xzf kafka 2.11 0.9 0.0 tgzbroker.id 0 整個集群內唯一id號,整數,一般從0開始 listeners plaintext 1....