注意：確保有JDK1.8版本及以上

官方文檔：https://kafka.apache.org/quickstart

清華鏡像下載：https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/

首先下載安裝包，在linux及Windows都可以使用。

1. Centos 安裝部署

1.1 下載

將下載好的安裝包上傳至服務器
解壓
```
tar -zxvf kafka_2.12-2.6.3.tgz
```

1.2 啟動zookeeper

后臺啟動zookeeper

kafka需要依賴ZK，安裝包中已經自帶了一個ZK，也可以改成指定已運行的ZK。
如果改成指定的ZK需要修改修改 kafka 安裝目錄下的 config/server.properties 文件中的zookeeper.connect 。這里使用自帶的ZK。
```
nohup ./bin/zookeeper-server-start.sh config/zookeeper.properties >> zookeeper.nohup &
```
檢查zookeeper是否啟動成功：
```
ps -ef|grep zookeeper
```

1.3 啟動Kafka

修改相關配置
```
vim config/server.properties
```
Broker ID啟動以后就不能改了
```
broker.id=0
```

取消注釋，改成本機IP；如果是云服務器記得開啟端口；

# 允許外部端口連接                                            
listeners=PLAINTEXT://0.0.0.0:9092  
# 外部代理地址                                                
advertised.listeners=PLAINTEXT://127.0.0.1:9092

num.partitions后面增加2行。
發送到不存在topic自動創建。允許永久刪除topic。
```
num.partitions=1
auto.create.topics.enable=true
delete.topic.enable=true
```

后臺啟動kafka（kafka安裝目錄下）：

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

1.4 創建Topic

sh bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

1.5 查看Topic

sh bin/kafka-topics.sh -list -zookeeper localhost:2181

1.6 啟動Producer

新窗口，在Kafka的解壓目錄下。

sh bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

1.7 啟動Consumer

開啟一個新的窗口，在Kafka的解壓目錄下。

sh bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

1.8 測試

2. Windows安裝部署

2.1 下載解壓

目錄結構：

2.2 啟動zookeepeer

打開CMD，執行如下命令：

bin\windows\zookeeper-server-start.bat config\zookeeper.properties

2.3 啟動Kafka

打開CMD，執行如下命令：

bin\windows\kafka-server-start.bat config\server.properties

2.4 創建Topic

bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic kafkaTest

2.4 查看Topic

bin\windows\kafka-topics.bat --list --zookeeper localhost:2181

2.5 啟動Producer

新開窗口。

bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic kafkaTest

2.6 啟動Consumer

新開窗口。

bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic kafkaTest --from-beginning

2.7 測試

---------------------
作者：、楽.
來源：CSDN
原文：https://blog.csdn.net/qq_41432730/article/details/121893405
版權聲明：本文為作者原創文章，轉載請附上博文鏈接！
內容解析By：CSDN,CNBLOG博客文章一鍵轉載插件