Service used to write to Kafka