1.下载Kafka3.0.0
下载地址：Kafka下载
我下载的是kafka_2.12-3.0.0.tgz 版本的，本文也是基于此版本。

2.安装
下载完成后上传到linux后，进行解压，命令：

tar -zxf kafka_2.12-3.0.0.tgz

然后进入解压后的目录，创建logs文件夹

cd kafka_2.12-3.0.0/
mkdir logs

之后进入config目录，修改 server.properties 的如下内容：

listeners=PLAINTEXT://localhost:9092
log.dirs=/software/kafka_2.12-3.0.0/logs

3.启动Kafka
先启动zookeeper
以守护进程启动zookeeper：

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

接着启动kafka：

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

在logs目录下查看server.log，如果提示started，则表示启动成功，不然就根据错误的原因重新修改。

4.简单测试
创建topic：

bin/kafka-topics.sh --create --topic test1 --bootstrap-server localhost:9092 --partitions 1 --replication-factor 1

查看topic：

bin/kafka-topics.sh --list --bootstrap-server localhost:9092

删除topic：

bin/kafka-topics.sh --delete --bootstrap-server localhost:9092 --topic name

生产消息：

bin/kafka-console-producer.sh --topic test1 --bootstrap-server localhost:9092

消费消息：

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