一、Linux環境準備

• Centos7， 1 CPU ， 2G Memory ，20G Disk ， Virtual System
• JDK
• Zookeeper

---

二、Kafka 安裝

下載Kafka安裝包
官網：http://kafka.apache.org/downloads

解壓安裝包 ：tar -zxvf kafka_2.11-2.3.1.tgz -C /opt/

修改配置文件
進入kafka安裝的config目錄下：cd /opt/kafka_2.11-2.3.1/config
修改server.properties文件：

---

三、Kafka常用操作

3.1、Kafka 啟動與關閉

啟動
（注意：在啟動kafka之前要啟動zookeeper服務及zookeeper的客戶）
進入kafka安裝目錄下，執行：

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

啟動完成

（新建會話，在Zookeeper目錄下執行：bin/zkCli.sh -server node110:2181）

---

3.2、Kafka Producer(生產者)

(記得先啟動kafka)

Producer創建Topic（建立HelloWorld話題）
(在kafka的目錄下執行)

bin/kafka-console-producer.sh --broker-list node110:9092 --topic HelloWorld

啟動完成

3.3、Kafka Consumer(消費者)

Consumer讀取Topic（消費HelloWorld話題）
(在kafka的目錄下執行)

bin/kafka-console-consumer.sh --bootstrap-server node110:9092 --topic HelloWorld --from-beginning

啟動完成

（根據末尾的參數不同，讀取到的結果信息數也不同）

總結

以上是生活随笔為你收集整理的学习笔记Kafka（三）—— Kafka安装配置（2）—— Kafka单代理及常用操作的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。