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
