Context

Debezium connectors can emit notification events related to internal state changes, such as:

• Snapshot completion

• Other events

Quarkus developers need a declarative mechanism to observe these events.

Decision

Introduce a series of events that are observable using @Observes like:

    @ApplicationScoped
    static class SnapshotNotificationsHandler {

        public void observe(@Observes SnapshotEvent event) {
            // here
        }

    }

References:

Debezium Design Document: https://github.com/debezium/debezium-design-documents/pull/16