rdhabalia opened a new pull request #2074: By default PulsarSource consume encrypted message URL: https://github.com/apache/incubator-pulsar/pull/2074 ### Motivation Right now, default CryptoFailureAction configuration is FAIL in `Consumer` which retries to consume message which is not applicable for pulsar-function because pulsar-function will never have CryptoReader configured. so, function should consume encrypted message and forward to sink along with EncryptionContext.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
