lhotari commented on PR #23172: URL: https://github.com/apache/pulsar/pull/23172#issuecomment-2291883993
> Correct, the hasBase64EncodedKey state is lost thus the key is not decoded into bytes. It caused problems with KeyValue<AVRO, AVRO, SEPARATED> data sent to DLQ - data from the DLQ cannot be read (avro exception, wrong format) with expected schema; it can be read only using KeyValue<BYTES, AVRO, SEPARATED> and manually decoding and parsing the key. This happens because it goes through getKeyBytes() which relies on `hasBase64EncodedKey()` status to decide whether to to do the base64 decoding Thanks for sharing the context @dlg99 -- 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]
