Great finding! Thanks Neng for fixing the issue!
- Sijie On Thu, Jul 22, 2021 at 6:24 PM Neng Lu <nl...@apache.org> wrote: > > 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
