freeznet opened a new pull request #9907: URL: https://github.com/apache/pulsar/pull/9907
Fixes #9851 ### Motivation Pulsar IO Source connector cannot pass message properties to destination topic, as #9851 discussed, it is a bug that `forwardSourceMessageProperty` is not applied to Source connector properly. ### Modifications - add `forwardSourceMessageProperty` to `SourceConfig` - add set `forwardSourceMessageProperty` from pulsar admin client - add related logic in `SourceConfigUtils` - add integration test ### Verifying this change - [ ] Make sure that the change passes the CI checks. ---------------------------------------------------------------- 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: [email protected]
