jthompson6 opened a new pull request #9216: URL: https://github.com/apache/kafka/pull/9216
The addBytes method adds the header using Schema.BYTES, which results in base64 encoding when the record is stored. SimpleHeaderConverter#toConnectHeader implements schema inference which we can use here, as the ConsumerRecord does not have header schema information. Testing: I added schema verification to the existing MirrorSourceTaskTest#testSerde, with a string and int example. ---------------------------------------------------------------- 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
