[CDCSDK] DBZ: Remove guard code to initialize OpId #18050
Labels
area/cdcsdk
CDC SDK
jira-originated
kind/new-feature
This is a request for a completely new feature
priority/low
Low priority
Jira Link: DB-7098
A guard logic was added in a PR #236 to forcefully use the checkpoints being sent by the service. However, in case of colocated tables, the guard caused issues causing the connector to request changes from an OpId previous than what was checkpointed.
To overcome the problem, 3 probable solutions are possible:
Remove the guard logic
Only update the fromLsn values in case of non-colocated tables
Update the explicit checkpoint values in case of colocated tables even for the records being skipped
The text was updated successfully, but these errors were encountered: