diff --git a/pulsar/schema/schema_avro.py b/pulsar/schema/schema_avro.py
index 480afe9..09b341b 100644
--- a/pulsar/schema/schema_avro.py
+++ b/pulsar/schema/schema_avro.py
@@ -91,7 +91,8 @@ def decode_message(self, msg: _pulsar.Message):
                 writer_schema = self._get_writer_schema(topic, version)
                 return self._decode_bytes(msg.data(), writer_schema)
             except Exception as e:
-                self._logger.error(f'Failed to get schema info of {topic} version {version}: {e}')
+                msg_id = msg.message_id()
+                self._logger.warn(f'Failed to decode {msg_id} with schema {topic} version {version}: {e}')
                 return self._decode_bytes(msg.data(), self._schema)
 
         def _get_writer_schema(self, topic: str, version: int) -> 'dict':