A pipeline that allows you to write simple java methods to answer questions based on data stored in Kafka Brokers. Done as a toy to compare the new Kafka 0.9 consumer to the 0.8.2 consumer and how greater control of handling offsets effect checkpointing state data.