💥 🚀 封装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