From 00bb8d39208dff1590d6f860ac2932ae86edb430 Mon Sep 17 00:00:00 2001
From: jedarden <github@jedarden.com>
Date: Thu, 2 Jul 2026 12:54:42 -0400
Subject: [PATCH] fix(cdc): fix rdkafka Header API usage

The rdkafka insert() method expects a Header struct, not a tuple.
Changed from .insert(("event_id", ...)) to .insert(Header::new("event_id", ...))

This fixes the miroir-release workflow build failures.
---
 crates/miroir-core/src/cdc.rs | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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