Great Job, cool Neng!!! -- Thanks Xiaolong Ran
Sijie Guo <guosi...@gmail.com> 于2021年7月24日周六 上午4:14写道: > 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 >