Package su.onno.kafka
package su.onno.kafka
-
ClassDescriptionApplication-defined handler for inbound CloudEvents.A decoded inbound CloudEvent delivered to
EventHandlers.Routes a decodedInboundEventto everyEventHandlerthat supports its type.Idempotency ledger for inbound CloudEvents.Kafka message listener that decodes the CloudEvents envelope, de-duplicates via theInbox, and dispatches to applicationEventHandlers through theInboundEventRouter.Inbound (consumer) settings.