Class KafkaConnectUtils

java.lang.Object
org.apache.beam.io.debezium.KafkaConnectUtils

public class KafkaConnectUtils extends Object
  • 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)