Custom Spark Kafka consumer based on Kafka SimpleConsumer API.
Primary LanguageScalaApache License 2.0Apache-2.0