handle

abstract fun handle(sagaId: String, command: TCommand)(source)

Performs the domain-specific compensation for a single event.

sagaId

saga correlation id from the inbound event envelope.

command

typed compensation command — exhaustive over the service's compensation actions.

Implementations should NOT swallow exceptions; let them propagate so the inbound Kafka listener can trigger broker-level retry / DLT.