💥 🚀 封装sparkstreaming动态调节batch time(有数据就执行计算)；🚀 支持运行过程中增删topic；🚀 封装sparkstreaming 1.6 - kafka 010 用以支持 SSL。
kafka spark splunk kudu hbase flink sparkstreaming flink-kafka ssc-dstream spark-kafka spark-es spark-kudu spark-hbase kafka-spark kafka-util es-shade sparkstreaming-kafka rabbitmq-util hbase-util kafka-ssl
-
Updated
Apr 15, 2021 - Scala