scylla-cdc-java
scylla-cdc-java copied to clipboard
Use long windows when catching up
Changes the strategy the CDC library uses to generate windows to read the CDC log. Previously, when a library was started, it would read queryTimeWindowSize large windows starting from |now - ttl|. The issue with that approach is that it requires a large number of windows to catch up, for example: 24 hours / 30 seconds * 256 * 8 = 5898240 for a 8-shard Scylla server.
A new approach just creates a single large window from |now - ttl| to |now - confidence window|.
v2: fixed flaky unit test. (off-by-one error)
Any news here? I'm pretty interested in this PR