1.下载Kafka3.0.0
下载地址：Kafka下载
我下载的是kafka_2.12-3.0.0.tgz 版本的，本文也是基于此版本。
2.安装
下载完成后上传到linux后，进行解压，命令：
tar -zxf kafka_2.12-3.0.0.tgz
1
然后进入解压后的目录，创建logs文件夹
cd kafka_2.12-3.0.0/
mkdir logs
1
2
之后进入config目录，修改 server.properties 的如下内容：
listeners=PLAINTEXT://localhost:9092
log.dirs=/software/kafka_2.12-3.0.0/logs
1
2
3.启动Kafka
先启动zookeeper
以守护进程启动zookeeper：
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
1
接着启动kafka：
bin/kafka-server-start.sh -daemon config/server.properties
1
在logs目录下查看server.log，如果提示started，则表示启动成功，不然就根据错误的原因重新修改。
4.简单测试
创建topic：
bin/kafka-topics.sh –create –topic test1 –bootstrap-server localhost:9092 –partitions 1 –replication-factor 1
1
查看topic：
bin/kafka-topics.sh –list –bootstrap-server localhost:9092
1
删除topic：
bin/kafka-topics.sh –delete –bootstrap-server localhost:9092 –topic name
1
生产消息：
bin/kafka-console-producer.sh –topic test1 –bootstrap-server localhost:9092
1
消费消息：
bin/kafka-console-consumer.sh –topic test1 –from-beginning –bootstrap-server localhost:9092
1
————————————————
版权声明：本文为CSDN博主「此木Y」的原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接及本声明。
原文链接：https://blog.csdn.net/weixin_43909382/article/details/123428612
