kafka-connect-protobuf-converter
kafka-connect-protobuf-converter copied to clipboard
Only supports primitive message fields?
I'm attempting to use this in a source connector to convert from connect format to protobuf and am getting an Unknown schema type: STRUCT
exception when it's trying to convert a google.protobuf.Int32Value
field. Poking around in the source code I see it doesn't handle any complex field types (map, array, struct).
Was this just because you haven't needed that for your protobuf messages and so haven't implemented that support yet, or is there some other reason you haven't done it?
@ctoomey This is the reason why we don't use this converter. It doesn't handle the most basic STRUCTS. If you're doing any CDC which has a before
and after
schema, this won't work for you. This converter needs love.
+1, Is this being worked on?