You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@cassandra.apache.org by "Jyothsna Konisa (Jira)" <ji...@apache.org> on 2026/05/13 17:32:00 UTC

[jira] [Created] (CASSSIDECAR-457) Fix CDC message loss during Sidecar restarts

Jyothsna Konisa created CASSSIDECAR-457:
-------------------------------------------

             Summary: Fix CDC message loss during Sidecar restarts
                 Key: CASSSIDECAR-457
                 URL: https://issues.apache.org/jira/browse/CASSSIDECAR-457
             Project: Sidecar for Apache Cassandra
          Issue Type: Task
            Reporter: Jyothsna Konisa


The analytics library's SidecarStatePersister calls EventConsumer.flush() before writing the CDC offset checkpoint at shutdown. Because flush() was a no-op, in-flight Kafka records were abandoned, and the checkpoint was advanced past them on restart, silently dropping events. The fix overrides flush() in CdcEventConsumer to call the blocking KafkaPublisher.flush(), ensuring all records are broker-acknowledged before the checkpoint is written.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org