jn-spark-streaming 一个流计算的容器示例。可在此基础上扩展开发相关实现。 目前实现了从rocketmq中读消费数据写到hive表的功能。 待实现： 读kafka；写redis；写hbase；完善消息队列消费的各种测试方法