Class DebeziumTypeConverter


  • @Converter(generateLoader=true)
    public final class DebeziumTypeConverter
    extends Object
    • Method Detail

      • toMap

        @Converter
        public static Map<String,​Object> toMap​(org.apache.kafka.connect.data.Struct struct)
        Convert Struct to HashMap, this only works with flat fields and it doesn't handle nested structure. Also as a result of the conversion, the schema data will be lost which is expected.
        Parameters:
        struct -
        Returns:
        Map