This is Kafka Writer for Spark. It's similar to Cloudera connector but in JAVA.