# :-: kafka集群搭建 **一、前提條件** 1、部署Kafka集群搭建需要服務器至少3臺，奇數臺 2、Kafka的安裝需要java環境，jdk1.8 3、Kafka安裝包版本：kafka\_2.12-2.7.0.tgz 4、假設3臺服務器分別為：kafka1、kafka2、kafka3 **二、Zookeeper集群搭建** 直接使用kafka自帶的zookeeper建立zk集群 1、將安裝包kafka\_2.12-2.7.0.tgz上傳到//usr/local/kafka目錄下 2、解壓：tar -zxvf kafka\_2.12-2.7.0.tgz 改名為kafka01 3、進入目錄：cd /usr/local/kafka/kafka01 4、創建zookeeper目錄：mkdir /usr/local/kafka/kafka01/zk\_datas 5、進入目錄：cd /usr/local/kafka/kafka01/config 6、修改zookeeper.properties文件：  ``` dataDir=/usr/local/kafka/kafka01/zk_datas clientPort=2181 maxClientCnxns=0 admin.enableServer=false ``` 同樣配置另外2臺kafka \*\*clientPort 為2182 2183 \*\* **dataDir=/usr/local/kafka/kafka02/zk\_datas dataDir=/usr/local/kafka/kafka03/zk\_datas** ***** **執行啟動** /usr/local/kafka/kafka01/bin/zookeeper-server-start.sh /usr/local/kafka/kafka01/config/zookeeper.properties >/dev/null 2>&1 & /usr/local/kafka/kafka02/bin/zookeeper-server-start.sh /usr/local/kafka/kafka02/config/zookeeper.properties >/dev/null 2>&1 & ***** **三、Kafka集群搭建** 1、進入目錄：cd /usr/local/kafka/kafka01 2、創建kafka日志數據目錄：mkdir /usr/local/kafka/kafka01/logs 3、進入目錄：cd /usr/local/kafka/kafka01/config 4、修改server.properties配置文件： ``` broker.id=0 listeners=PLAINTEXT://:9091 advertised.host.name=180.163.89.77 advertised.listeners=PLAINTEXT://180.163.89.77:9091 log.dirs=/usr/local/kafka/kafka01/logs zookeeper.connect=localhost:2181,localhost:2182 #開啟 刪除 topic 功能 delete.topic.enable=true #綁定節點的名稱,值為當前節點 host.name=node01 ``` \*\*\*\* ***** **5、 啟動kafka集群：** /usr/local/kafka/kafka01/bin/kafka-server-start.sh /usr/local/kafka/kafka01/config/server.properties 2>&1 & /usr/local/kafka/kafka02/bin/kafka-server-start.sh /usr/local/kafka/kafka02/config/server.properties 2>&1 & ***** kafka默認是自動創建topic，當你嘗試發送到topic或訂閱topic時，會自動創建topic ~~~ //創建topic bin/kafka-topics.sh --create --zookeeper 192.168.121.205:2181 --replication-factor 1 --partitions 1 --topic mykafka //查看topic bin/kafka-topics.sh --list --zookeeper 192.168.121.205:2181 //創建生產者 bin/kafka-console-producer.sh --broker-list 192.168.121.205:9092 --topic mykafka //創建消費者 bin/kafka-console-consumer.sh --zookeeper 192.168.121.205:2181 --topic mykafka --from-beginning ~~~ ***** **6、kafkaUI-1.2.3.jar**