RocketMQ 社区提供过
rocketmq-spark connector(在
apache/rocketmq-externals 里),可以像 Kafka 一样创建 DStream:
spark streaming消费rocketmq的几种方式
未经允许不得转载:小狮博客 » spark streaming消费rocketmq的几种方式
RocketMQ 社区提供过
rocketmq-spark connector(在
apache/rocketmq-externals 里),可以像 Kafka 一样创建 DStream: