fix: added schema to messages in batch_receive method (#215)

Danniilpz · web-flow · commit c449d886bb06 · 2025-05-16T20:02:30.000+08:00
diff --git a/pulsar/__init__.py b/pulsar/__init__.py
@@ -1602,6 +1602,7 @@ def batch_receive(self):
         for msg in msgs:
             m = Message()
             m._message = msg
+            m._schema = self._schema
             messages.append(m)
         return messages
 
