Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Converting byte[] to Kafka Connect data failed due to serialization error: java.io.CharConversionException: Invalid UTF-32 character 0xed7a2268. #182 #183

Open
sudheer9640 opened this issue Feb 3, 2022 · 1 comment

Comments

@sudheer9640
Copy link

While producing kafka message, Iam using encode method from kafkajs/confluent-schema-registry.
Iam passing Json schemaID and json payload as two params to this method.
In this method, payload is getting validated, converted to buffer and encoded with magic byte and some other encoding is happening.
So in http sink connector, when JSON value connector is used, iam facing this issue.
"value.converter": "org.apache.kafka.connect.json.JsonConverter",

So do I need to encode with magic byte when I use JSON schema as well

@NikitaKemarskiyLeia
Copy link

@sudheer9640 Have you managed to fix it?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants