add increment counter for publisher to fix duplicates on write. add event write to store with this counter, thus rewrite only if counter more then counter in request. then send event to broker with latest counter value, after which return response to publisher.