注意：确保有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博客文章一键转载插件