Distributed Message Service for Kafka