compensate

fun compensate(aggregateId: AggregateId, version: Int, target: CompensationTarget): Mono<Long>