This is a datasource implementation for quick query in Kafka with Spark - View it on GitHub