fix: Convert list from consumer to dict for message (#235)

radiorabe · Dec 31, 2024 · d40d783 · d40d783
1 parent ecc8ad9
commit d40d783
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/acringest.py b/acringest.py
@@ -172,11 +172,12 @@ def on_sigint(*_: Any) -> NoReturn:  # noqa: ANN401 # pragma: no cover
             mc.make_bucket(bucket)
 
     for msg in consumer:
+        headers: list[tuple[str, bytes]] = msg.headers if msg.headers else []
         ce: CloudEvent = from_structured(
             message=KafkaMessage(
                 key=msg.key,
                 value=msg.value,
-                headers=msg.headers if msg.headers else {},
+                headers={h[0]: h[1] for h in headers},
             ),
         )
         if (