LinMingQiang / sparkstreaming

封装sparkstreaming动态调节batch time(有数据就执行计算); 支持运行过程中增删topic; 封装sparkstreaming 1.6 - kafka 010 用以支持 SSL。
182Updated 3 years ago

Related projects

Alternatives and complementary repositories for sparkstreaming