org.apache.rocketmq:rocketmq-spark:0.0.1-SNAPSHOT 实际上在maven仓库可能找不到,需要下载源码打包,详见:https://github.com/apache/rocketmq-externals,附打包命令(rocketmq-spark目录):mvn clean install dependency:copy-dependencies -Dmaven.test.skip -Dcheckstyle.skip 当然可以直接在此处下载。
2021-10-13 18:07:48 478KB rocketmq-spark
1
由于spark streaming不支持从rocketmq中读取消息,本jar包是基于spark2.3.2和rocketmq4.2对官方源码进行编译的,有几个scala的bug已经解决。好东西拿出来大家分享,无需积分可以找我要哈。
2019-12-21 20:21:30 480KB rocketmq-spa
1