fix: when headers() returns None in AsyncConfluentParser, replace it …

…with an empty tuple (#1460)
airtai · May 21, 2024 · 2d224ee · 2d224ee
1 parent 13e46e9
commit 2d224ee
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/faststream/confluent/parser.py b/faststream/confluent/parser.py
@@ -20,7 +20,7 @@ async def parse_message(
         message: "Message",
     ) -> "StreamMessage[Message]":
         """Parses a Kafka message."""
-        headers = _parse_msg_headers(message.headers())
+        headers = _parse_msg_headers(message.headers() or ())
 
         body = message.value()
         offset = message.offset()
@@ -53,7 +53,7 @@ async def parse_message_batch(
 
         for m in message:
             body.append(m.value())
-            batch_headers.append(_parse_msg_headers(m.headers()))
+            batch_headers.append(_parse_msg_headers(m.headers() or ()))
 
         headers = next(iter(batch_headers), {})