Hello, I've encountered situation that results in a hanging debezium connector. The rootcause is that the debezium task can throw unchecked exception and that situation is not handled.
PR with the unit test and fix: https://github.com/apache/pulsar/pull/12441 I'd appreciate reviews and feedback. This should be mergeable down to 2.8. 2.7 code is quite different but it is possible to reimplement the fix there as well. Thank you. -- Andrey Yegorov