下载和安装
-
阿里云镜像下载地址：kafka_2.13-3.6.2.tgz
-
清华大学镜像下载地址：kafka_2.13-3.6.2.tgz
下载完成后解压即可，目录如下：
配置和使用
kafka的部署离不开zookeeper的，所以需要zookeeper。但是从kafka 3的版本之后自带了zookeeper，所以不需要我们去考虑zookeeper，只需配置 config/zookeeper.properties文件即可。如下图所示：
接着需要配置 config/server.properties文件
-
启动Zookeeper：
bin\windows\zookeeper-server-start.bat config\zookeeper.properties -
启动Kafka：
bin\windows\kafka-server-start.bat config\server.properties
错误信息【解决】： “提示输入行太长，命令语法不正确”
因为安装路径太深了。
确定启动成功
查看9092端口，若被占用则成功（kafka默认端口号）
netstat -ano | findstr "9092"
或者：
基本操作
-
创建主题
bin\windows\kafka-topics.bat --create --topic dragon-topic --bootstrap-server localhost:9092 -
查看主题
bin\windows\kafka-topics.bat --describe --topic dragon-topic --bootstrap-server localhost:9092
以上内容替换dragon-topic
-
发送者发送消息
bin\windows\kafka-console-producer.bat --topic dragon-topic --bootstrap-server localhost:9092 -
消费者消费消息
bin\windows\kafka-console-consumer.bat --topic dragon-topic --from-beginning --bootstrap-server localhost:9092
