diff --git a/crates/miroir-core/src/cdc.rs b/crates/miroir-core/src/cdc.rs
index cf0ba40..07dfc64 100644
--- a/crates/miroir-core/src/cdc.rs
+++ b/crates/miroir-core/src/cdc.rs
@@ -1780,7 +1780,7 @@ impl CdcManager {
                 .payload(&payload);
 
             // Add event_id header for consumer-side deduplication
-            let headers = OwnedHeaders::new().insert(Header::new("event_id", event.event_id.as_bytes()));
+            let headers = OwnedHeaders::new().insert(Header { key: "event_id", value: Some(event.event_id.as_bytes()) });
             record = record.headers(headers);
 
             // Send with timeout