Class DebeziumTypeConverter
- java.lang.Object
-
- org.apache.camel.component.debezium.DebeziumTypeConverter
-
@Converter(generateLoader=true) public final class DebeziumTypeConverter extends Object
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static Map<String,Object>
toMap(org.apache.kafka.connect.data.Struct struct)
ConvertStruct
toHashMap
, this only works with flat fields and it doesn't handle nested structure.
-
-
-
Method Detail
-
toMap
@Converter public static Map<String,Object> toMap(org.apache.kafka.connect.data.Struct struct)
ConvertStruct
toHashMap
, 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
-
-