An implementation of Kafka + Storm