kafka集群安裝（默認模式 無zookeeper安全認證）

kafka 集群安裝

1 安裝包來源

kafka官網(https://kafka.apache.org/downloads)：

kafka

# 2 集群服務器說明

服務器10.153.78.36，10.153.78.37，10.153.78.38三臺機器
每臺機器安裝一個zookeeper 節點,一個kafka server 節點

# 3 單臺（10.153.78.36）服務器配置（其他服務器類似)

# 使用kafka用戶登陸

groupadd kafka
useradd kafka
passwd kafka 

# 創建目錄與上傳包

mkdir /usr/local/src /** 創建目錄 **/
cd /usr/local/src /** 打開目錄 **/
rz -y /** 上傳kafka程序包 **/
tar -zxvf kafka_2.11-2.0.0.tgz /** 解壓包 **/
mv kafka_2.11-2.0.0 /usr/local/kafka /** 重命名目錄 **/
cd /usr/local/kafka/config /** 打開配置目錄 **/

# 修改zookeeper.properties以下內容

# vi zookeeper.properties /** 修改zookeeper配置 **/

dataDir=/usr/local/kafka/zookeeper /** 修改zookeepr數據路徑,kafka用戶必須有權限 **/ 

dataLogDir=/usr/local/kafka/log/zookeeper /** 修改zookeepr日誌路徑,kafka用戶必須有權限 **/
# the port at which the clients will connect
clientPort=2181 /** 修改zookeepr監聽端口,默認是2821 **/
 /** 修改zookeepr 集群通訊端口 **/
server.1=10.153.78.36:2888:3888 
server.2=10.153.78.37:2888:3888
server.3=10.153.78.38:2888:3888
 /** 保存退出 **/
:x

# 啟動zookeeper

cd /usr/local/kafka/bin /** 打開目錄 **/
./zookeeper-server-start.sh ../config/zookeeper.properties /** 啟動zookeeper **/

修改server.properties以下內容

cd /usr/local/kafka/config /** 打開目錄 **/
vi server.properties /** 編輯配置文件 **/
------------修改以下內容
broker.id=1 /** 設置server節點，每個服務器不一樣，36,37,38分別為1，2，3 **/
# A comma separated list of directories under which to store log files
log.dirs=/usr/local/kafka/kafka-logs /** kafka server日誌路徑 **/
# The default number of log partitions per topic. More partitions allow greater
# parallelism for consumption, but this will also result in more files across
# the brokers.
num.partitions=1 /** 消息主題分區 **/
#listeners=PLAINTEXT://:9092
port=9092 /** server端口 **/
host.name=10.153.78.36 /** 服務器IP **/
/** zookeeper集群連接串 **/
zookeeper.connect=10.153.78.36:2181,10.153.78.37:2181,10.153.78.38:2181

# 啟動kafka server

 cd /usr/local/kafka/bin /** 打開目錄 **/
./kafka-server-start.sh ../config/server.properties 

啟動成功查看日誌無誤即可

閱讀更多 大話軟件工程師 的文章

關鍵字: 技術 單臺 目錄