sijie opened a new pull request #10618: URL: https://github.com/apache/pulsar/pull/10618
*Motivation* After introducing the support for async functions, the java function processing semantic is not enforced. For example, if it fails to write a sink, it doesn't fail the java instance or fail the message. Hence it keeps receiving messages but never ack or nack. *Modification* Change the way how aysnc function requests are processed to fix the issues we have seen in Kinesis connector. -- 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]
