步骤
springboot简单集成kafka请看本人另外一篇文章springboot集成kafka基础入门
1.安装JDK
安装JAVA环境,这里不赘述,注意配置JAVA_HOME并确保安装成功
2.下载kafka
下载地址:http://kafka.apache.org/downloads
选择红框中的版本,Kafka包名组成: Scala版本 - Kafka自身版本
下官方推荐的版本
解压之后
bin是可执行文件
config是配置文件
3.启动kafka
打开bin\windows目录,该目录下是所有windows命令:
kafka自动zookeeper
我们需要的kafka启动脚本和zookeeper启动脚本
打开命令行,执行命令zookeeper-server-start.bat ..\..\config\zookeeper.properties
运行成功,2181端口,不要关闭窗口
再打开一个命令行,执行命令 kafka-server-start.bat ..\..\config\server.properties
运行成功,不要关闭窗口
4.测试
创建一个主题
命令行kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test-topic
创建了一个叫test-topic的topic
查看创建的主题列表
kafka-topics.bat --list --zookeeper localhost:2181
启动生产者:
kafka-console-producer.bat --broker-list localhost:9092 --topic test-topic
启动之后 随便输入点消息
启动消费者:
kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test-topic --from-beginning
接收到消息
接收到消息
以上就是下载并安装启动消费全过程