Package org.apache.beam.io.debezium

Class KafkaConnectUtils

java.lang.Object

org.apache.beam.io.debezium.KafkaConnectUtils

public class KafkaConnectUtils
extends Object

Constructor Summary

Constructors

Constructor	Description
KafkaConnectUtils()

Method Summary

Modifier and Type	Method	Description
static SourceRecordMapper<Row>	beamRowFromSourceRecordFn(Schema recordSchema)
static Schema	beamSchemaFromKafkaConnectSchema(org.apache.kafka.connect.data.Schema kafkaSchema)
static Schema.FieldType	beamSchemaTypeFromKafkaType(org.apache.kafka.connect.data.Schema kafkaFieldSchema)
static Instant	debeziumRecordInstant(org.apache.kafka.connect.source.SourceRecord record)

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaConnectUtils

public KafkaConnectUtils()

Method Details

beamSchemaFromKafkaConnectSchema

public static Schema beamSchemaFromKafkaConnectSchema(org.apache.kafka.connect.data.Schema kafkaSchema)

beamSchemaTypeFromKafkaType

public static Schema.FieldType beamSchemaTypeFromKafkaType(org.apache.kafka.connect.data.Schema kafkaFieldSchema)

debeziumRecordInstant

public static Instant debeziumRecordInstant(org.apache.kafka.connect.source.SourceRecord record)

beamRowFromSourceRecordFn

public static SourceRecordMapper<Row> beamRowFromSourceRecordFn(Schema recordSchema)