lhotari opened a new pull request #11822: URL: https://github.com/apache/pulsar/pull/11822
### Motivation I'm investigating an issue where setting batch-builder for a Debezium Postgres source doesn't seem to have an impact even after applying fixes made by #11706 for supporting `--batch-builder KEY_BASED` for sources. When reading the code, I found a special condition for ignoring the source record key. https://github.com/apache/pulsar/blob/3b651d910f39a29859434f0c5ba962c3ef8d2504/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/sink/PulsarSink.java#L370-L373 ### Modifications Remove the extra condition. Always set the output message key when the source record has a key. -- 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]
