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.
When I tried to run
mvn install
I got a bunch of incorrect -source errors.Added the config for the java compiler and specified a minimum source version.
Also added a .gitignore for build files (and whatever else)