diff --git a/crates/miroir-core/src/cdc.rs b/crates/miroir-core/src/cdc.rs
index 00087f0..cf0ba40 100644
--- a/crates/miroir-core/src/cdc.rs
+++ b/crates/miroir-core/src/cdc.rs
@@ -55,7 +55,7 @@ use async_nats::Client;
 
 #[cfg(feature = "kafka-sink")]
 use rdkafka::{
-    message::OwnedHeaders,
+    message::{Header, OwnedHeaders},
     producer::{FutureProducer, FutureRecord},
     ClientConfig,
 };
@@ -1780,7 +1780,7 @@ impl CdcManager {
                 .payload(&payload);
 
             // Add event_id header for consumer-side deduplication
-            let headers = OwnedHeaders::new().insert(("event_id", event.event_id.as_bytes()));
+            let headers = OwnedHeaders::new().insert(Header::new("event_id", event.event_id.as_bytes()));
             record = record.headers(headers);
 
             // Send with timeout