由于spark streaming不支持從rocketmq中讀取消息，本jar包是基于spark2.3.2和rocketmq4.2對官方源碼進行編譯的，有幾個scala的bug已經(jīng)解決。好東西拿出來大家分享，無需積分可以找我要哈。