A datapipe consisting of Kafka and Storm