and then assume that for multi-node case we write to some global message queue (e.g. kafka) that deals with transactionality