create
abstract fun create(topic: String, key: String, payload: ByteArray, sagaId: String?, eventId: String?): OutboxMessage(source)
Builds a new outbox message in OutboxStatus.PENDING.
Parameters
topic
Kafka destination topic.
key
Kafka record key (partitioning).
payload
Pre-serialized record value.
saga
Optional saga correlation id.
event
Optional caller-supplied event id; implementations generate one when null.