High Performance Kafka Connector for Spark Streaming.Supports Multi Topic Fetch, Kafka Security. Reliable offset management in Zookeeper. No Data-loss. No dependency on HDFS and WAL. In-built PID rate controller. Support Message Handler . Offset Lag checker.
Apache License 2.0
635
stars
318
forks
source link
Compilation fix for spark 2.0.0 and Scala 2.11 #32
I don't know if this changes are necessary but without I have compilation error.