[
https://issues.apache.org/jira/browse/CASSSIDECAR-457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jyothsna Konisa updated CASSSIDECAR-457:
----------------------------------------
Status: Ready to Commit (was: Review In Progress)
> 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
> Components: CDC
> Reporter: Jyothsna Konisa
> Assignee: Jyothsna Konisa
> Priority: Major
>
> 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: [email protected]
For additional commands, e-mail: [email protected]
