Re: Fix Debezium Connectors to pass integration test

2021-07-25 Thread r...@apache.org
Great Job, cool Neng!!! -- Thanks Xiaolong Ran Sijie Guo 于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 wrote: > > > > Hi All, > > > > I spent some time digging into the debezium connector integration test

Re: Fix Debezium Connectors to pass integration test

2021-07-23 Thread Sijie Guo
Great finding! Thanks Neng for fixing the issue! - Sijie On Thu, Jul 22, 2021 at 6:24 PM Neng Lu 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 t

Fix Debezium Connectors to pass integration test

2021-07-22 Thread Neng Lu
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 comm