This is an automated email from the ASF dual-hosted git repository. jyothsnakonisa pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/cassandra-sidecar.git
commit 9f8832b65f2ab57d4e8afd09bc0f7f27788f3fe3 Author: jkonisa <[email protected]> AuthorDate: Tue Mar 17 04:43:33 2026 -0700 CASSSIDECAR-457: Fix CDC message loss during Sidecar restarts Patch by Jyothsna Konisa; Reviewed by Josh McKenzie for CASSSIDECAR-457 --- CHANGES.txt | 1 + .../java/org/apache/cassandra/sidecar/cdc/CdcEventConsumer.java | 6 ++++++ 2 files changed, 7 insertions(+) diff --git a/CHANGES.txt b/CHANGES.txt index c2e668b0..bcba44a6 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,5 +1,6 @@ 0.4.0 ----- + * Fix CDC message loss during Sidecar restarts (CASSSIDECAR-457) * Fix CDC resource leaks: thread leaks, Kafka resource cleanup, singleton SidecarCdcClient (CASSSIDECAR-456) * Fix breaking changes for Analytics 0.4.0 (CASSSIDECAR-455) * Support IAM instance profile credentials for S3 restore jobs (CASSSIDECAR-415) diff --git a/server/src/main/java/org/apache/cassandra/sidecar/cdc/CdcEventConsumer.java b/server/src/main/java/org/apache/cassandra/sidecar/cdc/CdcEventConsumer.java index f79f4637..92db0077 100644 --- a/server/src/main/java/org/apache/cassandra/sidecar/cdc/CdcEventConsumer.java +++ b/server/src/main/java/org/apache/cassandra/sidecar/cdc/CdcEventConsumer.java @@ -42,6 +42,12 @@ public class CdcEventConsumer implements EventConsumer kafka.processEvent(cdcEvent); } + @Override + public void flush() throws InterruptedException + { + kafka.flush(); + } + public @NotNull Consumer<CdcEvent> andThen(@NotNull Consumer<? super CdcEvent> after) { return EventConsumer.super.andThen(after); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
