This is an automated email from the ASF dual-hosted git repository.
xyz pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pulsar-client-python.git
The following commit(s) were added to refs/heads/main by this push:
new c449d88 fix: added schema to messages in batch_receive method (#215)
c449d88 is described below
commit c449d886bb065697454bee5af9925d740e5a1e70
Author: Daniel López <[email protected]>
AuthorDate: Fri May 16 14:02:30 2025 +0200
fix: added schema to messages in batch_receive method (#215)
---
pulsar/__init__.py | 1 +
1 file changed, 1 insertion(+)
diff --git a/pulsar/__init__.py b/pulsar/__init__.py
index df7cad4..de8787f 100644
--- a/pulsar/__init__.py
+++ b/pulsar/__init__.py
@@ -1602,6 +1602,7 @@ class Consumer:
for msg in msgs:
m = Message()
m._message = msg
+ m._schema = self._schema
messages.append(m)
return messages
