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

步骤

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

1.安装JDK

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

2.下载kafka

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

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

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

下官方推荐的版本

解压之后

windows安装kafaka并且创建topci及发送消息
bin是可执行文件

config是配置文件

3.启动kafka

打开bin\windows目录,该目录下是所有windows命令:

kafka自动zookeeper

windows安装kafaka并且创建topci及发送消息
我们需要的kafka启动脚本和zookeeper启动脚本

打开命令行,执行命令zookeeper-server-start.bat ..\..\config\zookeeper.properties

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

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

再打开一个命令行,执行命令 kafka-server-start.bat ..\..\config\server.properties

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

运行成功,不要关闭窗口

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

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

启动生产者:

kafka-console-producer.bat --broker-list localhost:9092 --topic test-topic

启动之后 随便输入点消息

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

启动消费者:

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test-topic --from-beginning
windows安装kafaka并且创建topci及发送消息
接收到消息

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

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

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

上一篇:WPF 之命令(七)


下一篇:Flash中MP3导入及同步歌词图文教程