Package org.apache.beam.io.debezium
Class KafkaConnectUtils
java.lang.Object
org.apache.beam.io.debezium.KafkaConnectUtils
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic 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)
-
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
-
beamRowFromSourceRecordFn
-