jyothsnakonisa commented on code in PR #213:
URL: https://github.com/apache/cassandra-sidecar/pull/213#discussion_r2035894426
##########
server/src/main/java/org/apache/cassandra/sidecar/cdc/CdcConfigImpl.java:
##########
@@ -179,7 +179,7 @@ public MinuteBoundConfiguration watermarkWindow()
{
// this prop sets the maximum duration age accepted by CDC, any
mutations with write timestamps older than
// the watermark window will be dropped with log message "Exclude the
update due to out of the allowed time window."
- return new
MinuteBoundConfiguration(getInt(ConfigKeys.WATERMARK_SECONDS.lowcaseName,
DEFAULT_WATERMARK_WINDOW), TimeUnit.SECONDS);
+ return new
MinuteBoundConfiguration(getInt(ConfigKeys.WATERMARK_SECONDS.lowcaseName,
DEFAULT_WATERMARK_WINDOW) / 60, TimeUnit.MINUTES);
Review Comment:
We can change that but should that be minute granularity or seconds
granularity is the question. Also, note that it chages the API if we change it
to SecondBound
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
