1.下载Kafka3.0.0
下载地址：Kafka下载

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