io.debezium.config.Configuration |
CdcCommonConfiguration.configuration(CdcCommonProperties properties) |
EmbeddedEngine.Builder |
CdcCommonConfiguration.embeddedEngineBuilder(CdcCommonProperties properties,
org.apache.kafka.connect.storage.OffsetBackingStore offsetBackingStore) |
io.debezium.transforms.ExtractNewRecordState |
CdcCommonConfiguration.extractNewRecordState(CdcCommonProperties properties) |
org.apache.kafka.connect.json.JsonConverter |
CdcCommonConfiguration.jsonConverter(CdcCommonProperties properties) |
Function<org.apache.kafka.connect.source.SourceRecord,org.apache.kafka.connect.source.SourceRecord> |
CdcCommonConfiguration.recordFlattening(CdcCommonProperties properties,
io.debezium.transforms.ExtractNewRecordState extractNewRecordState) |