fix: added schema to messages in batch_receive method

apache · Jun 9, 2024 · 2032a50 · 2032a50
1 parent c3c12c4
commit 2032a50
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pulsar/__init__.py b/pulsar/__init__.py
@@ -1481,6 +1481,7 @@ def batch_receive(self):
         for msg in msgs:
             m = Message()
             m._message = msg
+            m._schema = self._schema
             messages.append(m)
         return messages