shibd opened a new pull request, #20816: URL: https://github.com/apache/pulsar/pull/20816
### Motivation When Kafka source poll message exception, it will throw it to the function framework, and not trigger the restart function instance. #20795 uses a new method on PulsarSource #20791 to fix it on master branch. To maintain compatibility, we can't cherry-pick it to the historical version, so the class is implemented in the Kafka source connector. ### Modifications - Let consumer.subscribe run on the start thread, which can quickly fail when subscribe exception. - Add new class `KafkaPushSource` on Kafka source connector. - When Kafka consumer exception, it will call `notifyError` to report the exception to the io connector framework. ### Documentation <!-- DO NOT REMOVE THIS SECTION. CHECK THE PROPER BOX ONLY. --> - [ ] `doc` <!-- Your PR contains doc changes. --> - [ ] `doc-required` <!-- Your PR changes impact docs and you will update later --> - [x] `doc-not-needed` <!-- Your PR changes do not impact docs --> - [ ] `doc-complete` <!-- Docs have been already added --> ### Matching PR in forked repository -- 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: commits-unsubscr...@pulsar.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
