LinMingQiang/sparkstreaming

:boom: :rocket: 封装sparkstreaming动态调节batch time(有数据就执行计算)；:rocket: 支持运行过程中增删topic；:rocket: 封装sparkstreaming 1.6 - kafka 010 用以支持 SSL。

语言：Scala · GitHub 星标：181 · Fork：81

话题：es-shade · flink · flink-kafka · hbase · hbase-util · kafka · kafka-spark · kafka-ssl

在 GitHub 上查看原仓库