Castle Router is an efficient implementation for querying data from Kafka - View it on GitHub