Storm Spout + Kafka State Inspector