@Experimental(value=SOURCE_SINK)

Package org.apache.beam.io.debezium

Transforms for reading from DebeziumIO.

See: Description

Interface Summary

Interface	Description
SourceRecordMapper<T>	Interface used to map a Kafka source record.

Class Summary

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().
DebeziumTransformRegistrar	Exposes DebeziumIO.Read as an external transform for cross-language usage.
DebeziumTransformRegistrar.ReadBuilder
DebeziumTransformRegistrar.ReadBuilder.Configuration
KafkaSourceConsumerFn<T>	Quick Overview
KafkaSourceConsumerFn.DebeziumSDFDatabaseHistory
SourceRecordJson	This class can be used as a mapper for each SourceRecord retrieved.
SourceRecordJson.SourceRecordJsonMapper	SourceRecordJson implementation.

Enum Summary

Enum	Description
Connectors	Enumeration of debezium connectors.

Package org.apache.beam.io.debezium Description

Transforms for reading from DebeziumIO.

See Also:

DebeziumIO