Package org.apache.iceberg.connect.transforms

Class MongoDebeziumTransform

java.lang.Object

org.apache.iceberg.connect.transforms.MongoDebeziumTransform

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.common.Configurable, org.apache.kafka.connect.transforms.Transformation<org.apache.kafka.connect.sink.SinkRecord>

public class MongoDebeziumTransform
extends Object
implements org.apache.kafka.connect.transforms.Transformation<org.apache.kafka.connect.sink.SinkRecord>

Debezium Mongo Connector generates the CDC before/after fields as BSON strings. This SMT converts those strings into typed SinkRecord Structs by inferring the schema from the BSON node types.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ARRAY_HANDLING_MODE_KEY
static final String	RECORD_ENVELOPE_KEY_SCHEMA_NAME_SUFFIX
static final String	SCHEMA_NAME_SUFFIX

Constructor Summary

Constructors

Constructor	Description
MongoDebeziumTransform()

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.connect.sink.SinkRecord	apply(org.apache.kafka.connect.sink.SinkRecord record)
void	close()
org.apache.kafka.common.config.ConfigDef	config()
void	configure(Map<String,?> configs)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

ARRAY_HANDLING_MODE_KEY

public static final String ARRAY_HANDLING_MODE_KEY

See Also:

• Constant Field Values

RECORD_ENVELOPE_KEY_SCHEMA_NAME_SUFFIX

public static final String RECORD_ENVELOPE_KEY_SCHEMA_NAME_SUFFIX

See Also:

• Constant Field Values

SCHEMA_NAME_SUFFIX

public static final String SCHEMA_NAME_SUFFIX

See Also:

• Constant Field Values

Constructor Details

MongoDebeziumTransform

public MongoDebeziumTransform()

Method Details

apply

public org.apache.kafka.connect.sink.SinkRecord apply(org.apache.kafka.connect.sink.SinkRecord record)

Specified by:

apply in interface org.apache.kafka.connect.transforms.Transformation<org.apache.kafka.connect.sink.SinkRecord>

config

public org.apache.kafka.common.config.ConfigDef config()

Specified by:

config in interface org.apache.kafka.connect.transforms.Transformation<org.apache.kafka.connect.sink.SinkRecord>

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface org.apache.kafka.connect.transforms.Transformation<org.apache.kafka.connect.sink.SinkRecord>

configure

public void configure(Map<String,?> configs)

Specified by:

configure in interface org.apache.kafka.common.Configurable