admin管理员组文章数量:1613040
一、kafka 安装
官网安装地址
安装前提,kafka安装运行最低支持jdk7;本篇演示版本是基于jdk1.8;
目前,Kafka已经内置了zookeeper,不需要单独下载zookeeper
windows下载后解压即可
二、启动
1.启动zookeeper
bin\windows\zookeeper-server-start.bat config\zookeeper.properties
这边会报一个奇葩的错误,命令行太长,直接将压缩包解压到根目录或者桌面进行操作
尽量减少文件夹名字长度或不要嵌套太多层文件夹
启动成功
2.启动kafka
启动kafka服务端命令
bin\windows\kafka-server-start.bat config\server.properties
启动成功
三、使用
1.创建Topic
bin/windows/kafka-topics.bat --create --bootstrap-server localhost:9092 --topic test --partitions 1 --replication-factor 1
上述命令创造了test主题
2.查看Topic
bin/windows/kafka-topics.bat --list --bootstrap-server localhost:9092
3.发送消息
前面介绍Kafka专业术语中已经阐述,Kafka使用过程中首先需要消息生产者发送消息,那么消费者才可以读取到消息。
启动一个终端A,执行下面命令,
> bin/windows/kafka-console-producer.bat --broker-list localhost:9092 --topic test
> hello
当执行producer脚本后,会出现消息输入提示符,这是我们可以输入消息(数据),然后它会发送到对应的服务器(Broker)。
4.接收消息
现在管道中已经有了数据,接下来我就可以使用消费者去读取数据。
另外启动一个终端B,执行下面命令,
> ./bin/windows/kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test
hello world
版权声明:本文标题:Windows下 kafka安装及使用 内容由热心网友自发贡献,该文观点仅代表作者本人, 转载请联系作者并注明出处:https://m.elefans.com/xitong/1728649740a1167877.html, 本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容,一经查实,本站将立刻删除。
发表评论