Hi All, I spent some time digging into the debezium connector integration test issue. And found that currently the connector's `ack()` method is a blocking call. This results in the blocking of two threads (public/default/debezium-mongodb-source-0 and pulsar-io-X) and thus the offset is never committed successfully.
I have prepared a fix here: https://github.com/apache/pulsar/pull/11435 Best Regards, Neng Lu
