jedarden/miroir
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fix(cdc): fix rdkafka Header API usage

Browse source 
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.
This commit is contained in:
jedarden 2026-07-02 12:54:42 -04:00
parent 9b76469dad
commit 00bb8d3920
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
crates/miroir-core/src/cdc.rs
View file

@ -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