markCompleted

@Transactional(propagation = Propagation.REQUIRES_NEW)

Fresh REQUIRES_NEW transaction that marks message as successfully published. Called after the Kafka broker has acknowledged to send.