由于spark streaming不支持从rocketmq中读取消息,本jar包是基于spark2.3.2和rocketmq4.2对官方源码进行编译的,有几个scala的bug已经解决。好东西拿出来大家分享,无需积分可以找我要哈。
2019-12-21 20:21:30 480KB rocketmq-spa
1