Extracts fields from a raw Java SourceRecord object (EngineFormat.CONNECT). Zero JSON overhead: reads Java Struct objects directly via JP

Extracts fields from a Debezium ChangeEvent (Java object, passed via JPype). When using JSON format (EngineFormat.JSON): - key()

Controls how Java Connect values are converted to Python values. Attributes: numeric_mode: - "native": Python int/f

Handler for Connect mode - receives raw Java SourceRecord objects. No JSON parsing happens.

Debezium embedded engine using Connect format (EngineFormat.CONNECT). Key difference from DebeziumJsonEngine: - No JSON serializatio

The payload section of a Debezium JSON envelope. op values: 'c' = create (INSERT) 'u' = update (UPDATE) 'd' =

Represents the schema section of a Debezium JSON envelope. Contains field definitions, types, and metadata about the message structure.

The schema section of a Debezium JSON envelope.

Integrator for Hibernate ORM that enables aggregate materialization via {@link MaterializeAggregate}. @author Gunnar Morling

Hibernate event listener that materializes aggregates for given entities via JSON into a separate table. @author Gunnar Morling

Registers the custom work item handlers used by the BPMN processes. In Kogito the handler name must match the work item type generated for the BPMN ta

Abstract base class for handlers that receive Debezium events in Connect format. Unlike BasePythonChangeHandler (which gets JSON strings)

Keeps track of the position within the key/value state store that is used as a buffer for non-joinable events. As there's no true queue like structure

Demo for using the Debezium Embedded API to send change events to Amazon Kinesis.

Demo for using the Debezium Embedded API to send change events to Amazon Kinesis.

A {@link Serde} that (de-)serializes JSON. The {@link Deserializer} supports Debezium's CDC message format, i.e. for such messages the values to be de

Enriches change events with transaction-scoped metadata. If no metadata for the associated transaction can be retrieved yet (as the change event gets

A value object that represents a request to create a {@link PurchaseOrder}.

A value object that represents a request to create a {@link PurchaseOrder}.

Listens to database changes using Debezium's embedded engine. If a change event for an {@link Item} arrives that has not been caused by this applicati

Full validated Pydantic model for a Debezium CDC event. Combines destination, schema, and payload.

A Python-native representation of a single Debezium CDC event. Fields: destination: The topic/table where the event originates.

A single field in a Debezium schema definition.

An exception that indicates an entity could not be found.

An exception that indicates an entity could not be found.

An exception mapper for {@link EntityNotFoundException} errors.

An exception mapper for {@link EntityNotFoundException} errors.

Triggers change events by persisting {@link Order} records. @author Gunnar Morling

Triggers change events by persisting {@link Order} records. @author Gunnar Morling

Takes Kafka Connect schema and JSON payload from a message and expands it into a properly typed record. @author Gunnar Morling @param <R>