golang-cqrs-kafka-publisher