1、搭建軟體環境
1)linux一台或多台,大於等於2
2)已經搭建好的zookeeper集群
2、解壓tar –zxvf kafka_2.10-0.10.1.1.tgz;
3、在kafka安裝目錄下,新建目錄kafkalogs;
4、在config目錄下修改配置檔案server.properties,
broker.id=0 每台伺服器的broker.id都不能相同
port=19092
#hostname
host.name=192.168.x.***
#在log.retention.hours=168 下面新增下面三項
message.max.byte=5242880
default.replication.factor=2
replica.fetch.max.bytes=5242880
#設定zookeeper的連線埠
zookeeper.connect=192.168.x.1xx:12181,192.168.x.2xx:12181,192.168.x.3xx:12181
5、啟動kafka集群,./kafka-server-start.sh-daemon ../config/server.properties
6、檢查服務是否啟動,jps | grepkafka
7、建立topic來驗證是否建立成功:
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....
kafka 集群搭建
1 前置條件 安裝jdk zookeeper 集群搭建 wget tar xzf kafka 2.11 0.10.2.1.tgz 3 修改 config server.properties 三個地方 1 broker.id 要對上 log.dirs 下 meta.properties broker....
kafka集群搭建
1 上傳安裝包 把安裝包上傳到伺服器 put r d kafka 2.11 0.8.2.0.tgz 2 解壓縮安裝包 3 配置kafka環境變數 vim etc profile export path path kafka home bin 重新整理策略 source etc profile 4 修...