Package-level declarations

Persistence-agnostic contract for a Kafka outbox message.

Persistence-agnostic factory that produces a new OutboxMessage instance matching the storage backend in use (JPA entity, Mongo document, Cassandra row, …).

Persistence-agnostic repository port for the Kafka outbox.

Persistence-agnostic status of an outbox message.

Persistence-agnostic record of an event already processed by a Kafka consumer group. Backbone of the consumer-side idempotent receiver pattern (Hohpe & Woolf, Enterprise Integration Patterns).

Persistence-agnostic factory for ProcessedEvent rows, owned by each service's adapter (analogous to OutboxMessageFactory).

Persistence-agnostic repository port for ProcessedEvent rows.