ArnavBalyan opened a new pull request, #7871:
URL: https://github.com/apache/paimon/pull/7871
### Purpose
- KafkaDebeziumAvroDeserializationSchema resolves a single topic via
findOneTopic at init time and reuses it for every record's lookup.
- With multi topic configs (topic=a;b), any message from some other topic
crash with `SerializationException: The given schema does not match`. The same
cached topic is also passed into `CdcSourceRecord`, misrouting records to the
wrong target table.
- Read topic from the actual message for deserialize instead of setting
once at init time.
- Closes user reported bug #7859.
### Tests
- Existing UTs
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
