A {@link SerializationFormat} defining the undefined serialization type.

Basic services provided to all change consumers. @author Jiri Pechanec

Converts Debezium Server's ChangeEvent (EmbeddedEngineChangeEvent) to Kafka Connect's SinkRecord for use with JdbcChangeEventSink. <p> This is a simpl

Client authentication methods per RFC 6749.

Fired when the connector was completed. Provides information about completion state, message and optional stacktrace in case of error. @author Jiri P

The server lifecycle listener that published CDI events based on the lifecycle changes and also provides Microprofile Health information. @author Jir

Fired when the connector is started. The initialization is completed but the execution task is not started yet. @author Jiri Pechanec

Fired when the connector is stopped but the final execution completion state is not yet determined. @author Jiri Pechanec

Reads debezium source pipeline metrics. NOTE: calls for reading metrics should be made after debezium connector initialized, after connector registers

<p>The entry point of the Quarkus-based standalone server. The server is configured via Quarkus/Microprofile Configuration sources and provides few ou

Integration test that verifies basic reading from PostgreSQL database. @author Oren Elias

Integration test that verifies Debezium server is able to deliver records in Kafka Connect format. @author vjuranek

Integration test that verifies basic reading from PostgreSQL database. @author Jiri Pechanec

Integration test that verifies basic reading from PostgreSQL database. @author Fiore Mario Vitale

Common interface for all Debezium Server sink implementations. <p> This interface extends {@link ConfigDescriptor} to provide configuration metadata a

Smoke test that verifies the basic functionality of Quarkus-based server. @author Jiri Pechanec

Proxy class/wrapper for EventDataBatch. Will create an inner EventDataBatch when data is being emitted to a specific partition.

This sink adapter delivers change event messages to Azure Event Hubs @author Abhishek Gupta

Configuration fields for {@link EventHubsChangeConsumer}.

Integration test that verifies basic reading from PostgreSQL database and writing to Azure Event Hubs using a fixed partition key. @author Sebastiaan

Integration test that verifies basic reading from PostgreSQL database and writing to Azure Event Hubs. @author Abhishek Gupta

Integration test that verifies basic reading from PostgreSQL database and writing to Azure Event Hubs. @author Abhishek Gupta

Integration test that verifies the Fluss sink auto-creates tables from the Debezium event schema. @author Chris Cranford

Test profile that auto-creates the target table for the specified source include tables. @author Chris Cranford

An implementation of the {@link io.debezium.engine.DebeziumEngine.ChangeConsumer} interface that publishes change event messages to Apache Fluss. <p>

Configuration fields for {@link FlussChangeConsumer}. @author Chris Cranford

Integration test that verifies reading from PostgreSQL and writing to Apache Fluss using the Kafka Connect format. @author Chris Cranford

Specifies for the test to use the {@code Connect} key, value, and header formats. @author Chris Cranford

Integration test that verifies reading from PostgreSQL and writing to Apache Fluss. @author Chris Cranford

Apache Fluss test suite configuration. @author Chris Cranford

Manages the lifecycle of a Fluss cluster (ZooKeeper + coordinator + tablet server) for integration testing. <p>Uses host networking so that the Fluss

Converter for all Kafka Connect to Apache Fluss type mapping. <p>Handles both schema-level conversion (Connect {@link org.apache.kafka.connect.data.S

Unit tests for {@link FlussTypeConverter}. @author Chris Cranford

Unit tests for Apache Fluss. @author Chris Cranford

Integration test that verifies the Fluss sink writes correctly to a primary-key table when {@code primary.key.mode=upsert} is configured. @author Chr

Test profile that enables upsert mode and uses a distinct topic prefix so the target Fluss table is separate from the log table used by {@link FlussIT

Enumeration of supported hash functions for message key hashing.

Implementation of the consumer that delivers the messages to an HTTP Webhook destination. @author Chris Baumbauer

Configuration fields for {@link HttpChangeConsumer}.

Integration test that verifies basic reading from PostgreSQL database and writing to an HTTP Server @author Chris Baumbauer

The list of container images used in testing

An implementation of the {@link DebeziumEngine.ChangeConsumer} interface that publishes change event messages to predefined Infinispan cache. @author

Configuration fields for {@link InfinispanSinkConsumer}.

@author vjuranek

InstructLab sink integration tests. @author Chris Cranford

An implementation of the {@link ChangeConsumer} interface that appends change event messages to the InstructLab's {@code qna.yml} file, to improve tra

Configuration fields for {@link InstructLabSinkConsumer}.

Defines the test configuration for the InstructLab integration tests. @author Chris Cranford

Implements the logic for authenticating against an endpoint supporting the JSON Web Tokens (JWT) scheme. Once authentication is successful, the authe

Implementation of the consumer that delivers change events to a JDBC database using the Debezium JDBC connector. <p> This consumer wraps JdbcChangeEve

Configuration wrapper for JDBC sink in Debezium Server. Maps debezium.sink.jdbc. properties to the format expected by JdbcSinkConnectorConfig. This a

Integration tests for JDBC sink with PostgreSQL source and target. <p> Tests cover: - Initial snapshot replication - INSERT operations - UPDATE operat

Test configuration for JDBC sink integration tests.

Manages lifecycle of a PostgreSQL container used as the JDBC sink target. This is separate from the source PostgreSQL managed by PostgresTestResourceL

Utility methods for JDBC integration tests.

An implementation of the {@link DebeziumEngine.ChangeConsumer} interface that publishes change event messages to Kafka.

Configuration fields for {@link KafkaChangeConsumer}.

Integration test for verifying that the Kafka sink adapter can stream change events from a PostgreSQL database to a configured Apache Kafka broker. @

Integration test for verifying that the Kafka sink adapter can stream change events from a PostgreSQL database to a configured Apache Kafka broker. @

Manages the lifecycle of a Kafka cluster test resource. @author Alfusainey Jallow

Implementation of the consumer that delivers the messages into Amazon Kinesis destination. @author Jiri Pechanec

Configuration fields for {@link KinesisChangeConsumer}.