/kafka-connect-transform-flatten-avro

flatten avro if it's nested, optional and null

Primary LanguageJavaMIT LicenseMIT

kafka-connect-transform-flatten-avro

Kafka Connect Single Message Transform to flatten optional null value in avro

The original flatten has the drawback of throwing NPE when nested optional schema has null value

How to use

add the following config to your connector

"transforms": "flattenAvro",
"transforms.flattenAvro.type": "org.sendoh.kafka.connect.transforms.FlattenAvro$Value",