ArnavBalyan opened a new pull request, #6116:
URL: https://github.com/apache/paimon/pull/6116
- Fixes #5945
- KafkaDebeziumJsonDeserializationSchema always parses Kafka keys as JSON,
causing deserialization for fail for non JSON
- CDC pipelines only use the JSON value payload, handle this gracefully by
ignoring the non json fields.
- Prevents crashes for topics with raw keys.
--
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.
To unsubscribe, e-mail: issues-unsubscr...@paimon.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
