Package org.apache.beam.io.debezium

package org.apache.beam.io.debezium

Transforms for reading from DebeziumIO.

See Also:

• DebeziumIO

Class	Description
Connectors	Enumeration of debezium connectors.
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.
SourceRecordMapper<T>	Interface used to map a Kafka source record.