Custom Spark Kafka consumer based on Kafka SimpleConsumer API.