怎么建设微信网站,网页访问紧急升级,wordpress to cms,跨界营销案例这里提供了windows下的java1.8和kafka3.9.0版本汇总#xff0c;可直接免费下载
【免费】java1.8kafka2.13版本汇总资源-CSDN文库
解压后可以得到一个文件夹 资料汇总内有一个kafka文件资料包.tgz#xff0c;解压后可得到下述文件夹kafka_2.13-3.9.0#xff0c;资料汇总内还…这里提供了windows下的java1.8和kafka3.9.0版本汇总可直接免费下载
【免费】java1.8kafka2.13版本汇总资源-CSDN文库
解压后可以得到一个文件夹 资料汇总内有一个kafka文件资料包.tgz解压后可得到下述文件夹kafka_2.13-3.9.0资料汇总内还有一个jdk文件直接下载即java版本
将文件夹kafka_2.13-3.9.0改名为kafka并移动到c盘或d盘下方 打开后可以看到相关文件data文件夹zk.cmd以及kafka.cmd这几个文件是后期添加的 手动新建一个文件夹data用于存放kafka以及zookeeper缓存数据并在data中新建kafka和zk两个文件夹 进入config文件夹修改zookeeper.properties文件找到dataDirC:/kafka/data/zk将地址填写为刚才的新建zk文件夹 同样的修改server.properties修改log.dirsC:/kafka/data/kafka地址为刚才的新建kafka地址 回到文件夹主目录新建kafka.cmd文件右键打开方式为文本方式写入下述内容
call bin/windows/kafka-server-start.bat config/server.properties
新建zk.cmd文件右键打开方式为文本方式写入下述内容
call bin/windows/zookeeper-server-start.bat config/zookeeper.properties
至此文件配置环节已经完成
接下来就要开始一个简单的demo
首先双击zk.cmd启动zookeeper再双击kafka.cmd启动kafka需要注意的是关闭的时候需要先关闭kafka再关闭zookeeper
容易出现报错问题如果你未将文件夹移动到c盘或者d盘或者未改名文件夹容易导致命令行语句过长产生错误这一点需要注意 zookeeper kafka 再启动完成后接下来需要创建topic以及producer和consumer 进入 bin 文件夹下的 windows 文件夹打开 cmd 命令窗口运行下方命令创建topic
# --bootstrap-server localhost:9092 配置服务器连接此处为本机9092为kafka默认端口号
# --topic test 创建topic主题主题名称为 test
# --create 创建topic主题命令
kafka-topics.bat --bootstrap-server localhost:9092 --topic test --create 创建完topic后要进行producer的创建
依然在bin下执行cmd输入下述语句
# 运行 kafka-console-producer.bat 脚本创建生产者连接本机9092端口名为 test 的主题
kafka-console-producer.bat --bootstrap-server localhost:9092 --topic test 最后创建消费者consumer 依然在bin下执行cmd输入下述语句
# 运行 kafka-console-consumer.bat 脚本创建消费者连接本机9092端口名为 test 的主题
windowskafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test
至此连接完成直接在producer中写语句可在consumer中得到同步
