Thorne
Thorne
@whhe PTAL
> I think adding a server id can indeed solve the issue, and a LifecycleListener is also needed for other exceptions. Can you add a basic implementation like `ReaderThreadLifecycleListener` please?...
May be we should consider fix the BinaryLogClient with LifecycleListener in a new pr ,because another pr also should be fixed https://github.com/apache/flink-cdc/pull/1915/
@ruanhang1993 Desc： 1. If the binaryLogClient does not have a registered server-id, the binaryLogClient will use the default `65535` parameter. If there is only one source in a Flink job,...
@leonardBang PTAL
another [pr:[](https://github.com/apache/flink-cdc/pull/3598)]
> Thanks for @uicosp's great work! It's indeed a long awaited feature. > > Seems Debezium has a similar option called [`snapshot.select.statement.overrides`](https://debezium.io/documentation/reference/stable/connectors/mysql.html#mysql-property-snapshot-select-statement-overrides), which allows users to project out unwanted columns...
Should we consider this pr with only `snapshot ` startoption and back fill ?
> debezium.snapshot.select.statement.overrides `debezium.snapshot.select.statement.overrides` option only applicable to read data by lock algorithms，this is incremental snapshot for capturing data. You can completely implement other incremental snapshot connectors methods by following the...