315157973 opened a new pull request #7772: URL: https://github.com/apache/pulsar/pull/7772
Fixes #7622 ### Motivation 1 We cannot specify the consume position of the function 2 Pulsar Functions doesn't expose the producer settings publicly ### Modifications 1 The `subscription position` setting already exists in the code, but this parameter is not exposed to the outside, so I exposed this setting in `FunctionConfig` 2 Added the general parameter `outputSpecs`, all producer settings can be passed in through it. 3 Expose the producer settings publicly to pulsar source as well ### Verifying this change unit tests org.apache.pulsar.io.PulsarFunctionE2ETest#testOutputSpecs org.apache.pulsar.io.PulsarFunctionE2ETest#testReadPositionEarliest org.apache.pulsar.io.PulsarFunctionE2ETest#testReadPositionLatest org.apache.pulsar.io.PulsarFunctionE2ETest#testSinkProducerSetting ---------------------------------------------------------------- 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]
