搭建kafka集群

(搭建kafka之前需提前搭建zookeeper集群，本文沒有寫zookeeper搭建過程)

cd /opt/

mkdir kafka #建立專案目錄

tar -zxvf kafka_2.12-1.1.0.tgz

cd /opt/kafka/kafka_2.12-1.1.0/
mkdir log #建立kafka訊息目錄，主要存放kafka訊息

cd /opt/kafka/kafka_2.12-1.1.0/config

vi server.properties

broker.id=1#當前機器在集群中的唯一標識（每台機器的id不同）

listeners=plaintext://hostname:9092# (listeners是kafka真正bind的位址)

advertised.listeners=plaintext://hostname:9092#( advertised.listeners是暴露給外部的listeners，如果沒有設定，會用listeners)

log.dirs=/opt/kafka/kafka_2.12-1.1.0/log#訊息存放的目錄

zookeeper.connect=ip01:2181,ip02:2181,ip03:2181#設定zookeeper的連線埠

cd /opt/kafka/kafka_2.12-1.1.0

nohup ./bin/kafka-server-start.sh  config/server.properties &

jps

檢視topic命令：

/opt/kafka/kafka_2.12-1.1.0/bin/kafka-topics.sh --list –zookeeper ip01:2181,ip02:2181,ip03:2181

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 修...