Skip to content

Commit 5653c64

Browse files
Matt Howlettcaptain-kark
andauthored
Have fastavro log on deserialization failures (#1058)
Co-authored-by: captain-kark <[email protected]>
1 parent e65febf commit 5653c64

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

src/confluent_kafka/avro/serializer/message_serializer.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -189,8 +189,7 @@ def _get_decoder_func(self, schema_id, payload, is_key=False):
189189
p, fast_avro_writer_schema, fast_avro_reader_schema)
190190
return self.id_to_decoder_func[schema_id]
191191
except Exception:
192-
# Fast avro failed, fall thru to standard avro below.
193-
pass
192+
log.warning("Fast avro failed for schema with id %d, falling thru to standard avro" % (schema_id))
194193

195194
# here means we should just delegate to slow avro
196195
# rewind

0 commit comments

Comments
 (0)