| Interface | Description |
|---|---|
| SourceRecordMapper<T> |
Interface used to map a Kafka source record.
|
| Class | Description |
|---|---|
| DebeziumIO |
Utility class which exposes an implementation
DebeziumIO.read() and a Debezium configuration. |
| DebeziumIO.ConnectorConfiguration |
A POJO describing a Debezium configuration.
|
| DebeziumIO.Read<T> |
Implementation of
DebeziumIO.read(). |
| DebeziumReadSchemaTransformProvider |
A schema-aware transform provider for
DebeziumIO. |
| DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration | |
| DebeziumReadSchemaTransformProvider.DebeziumReadSchemaTransformConfiguration.Builder | |
| DebeziumTransformRegistrar |
Exposes
DebeziumIO.Read as an external transform for cross-language usage. |
| DebeziumTransformRegistrar.ReadBuilder | |
| DebeziumTransformRegistrar.ReadBuilder.Configuration | |
| KafkaConnectUtils | |
| KafkaSourceConsumerFn<T> |
Quick Overview
|
| KafkaSourceConsumerFn.DebeziumSDFDatabaseHistory | |
| SourceRecordJson |
This class can be used as a mapper for each
SourceRecord retrieved. |
| SourceRecordJson.SourceRecordJsonMapper |
SourceRecordJson implementation. |
| Enum | Description |
|---|---|
| Connectors |
Enumeration of debezium connectors.
|
DebeziumIO