We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f9b2d16 commit 2940c60Copy full SHA for 2940c60
pulsar/schema/schema_avro.py
@@ -91,7 +91,8 @@ def decode_message(self, msg: _pulsar.Message):
91
writer_schema = self._get_writer_schema(topic, version)
92
return self._decode_bytes(msg.data(), writer_schema)
93
except Exception as e:
94
- self._logger.error(f'Failed to get schema info of {topic} version {version}: {e}')
+ msg_id = msg.message_id()
95
+ self._logger.warn(f'Failed to decode {msg_id} with schema {topic} version {version}: {e}')
96
return self._decode_bytes(msg.data(), self._schema)
97
98
def _get_writer_schema(self, topic: str, version: int) -> 'dict':
0 commit comments