gohanbg commented on issue #843: URL: https://github.com/apache/camel-kafka-connector/issues/843#issuecomment-758164904
Hi @valdar Inside kafka topic itself, messages are in `Avro` format. If I try to use `org.apache.kafka.connect.json.JsonConverter` I get a parsing exception - ``` Caused by: org.apache.kafka.common.errors.SerializationException: java.io.CharConversionException: Invalid UTF-32 character 0x515486f (above 0x0010ffff) at char #1, byte #7) Caused by: java.io.CharConversionException: Invalid UTF-32 character 0x515486f (above 0x0010ffff) at char #1, byte #7) ``` If I use the StringConverter this is what reaches S3: ``` House Stark�https://static.wikia.nocookie.net/gameofthrones/images/8/8a/House-Stark-Main-Shield.PNG/revision/latest/scale-to-width-down/400?cb=20170101103142�https://media-exp1.licdn.com/dms/image/C4E1BAQEY67rO9YNpIw/company-background_10000/0?e=1592661600&v=beta&t=w0K0h9L18D6HieYM1giMf7TqKGne4LKqieuENS4RqDwH7d4cb366-aedf-476e-b3fc-61b9b1fc55eb% ``` I guess the JsonConverter tries to parse the exact same string and find unexpected characters. Only with `io.confluent.connect.avro.AvroConverter` I see a nicely parsed object, but it can't reach S3 :( Regards Mihail Yordanov ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
