Version of the splitter service, that is implemented with Kafka-Client-API