windows安装kafaka并且创建topci及发送消息

步骤

springboot简单集成kafka请看本人另外一篇文章springboot集成kafka基础入门

1.安装JDK

安装JAVA环境,这里不赘述,注意配置JAVA_HOME并确保安装成功

2.下载kafka

下载地址：http://kafka.apache.org/downloads

选择红框中的版本，Kafka包名组成： Scala版本 - Kafka自身版本

下官方推荐的版本

解压之后

bin是可执行文件

config是配置文件

3.启动kafka

打开binwindows目录，该目录下是所有windows命令：

kafka自动zookeeper

我们需要的kafka启动脚本和zookeeper启动脚本

打开命令行，执行命令zookeeper-server-start.bat ....configzookeeper.properties

运行成功,2181端口,不要关闭窗口

再打开一个命令行，执行命令 kafka-server-start.bat ....configserver.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

接收到消息

接收到消息

以上就是下载并安装启动消费全过程