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.
2 parents f83e522 + 706422d commit b2ca1d6Copy full SHA for b2ca1d6
aiokafka/consumer/fetcher.py
@@ -214,7 +214,7 @@ def _unpack_records(self):
214
if self._check_crcs and not next_batch.validate_crc():
215
# This iterator will be closed after the exception, so we don't
216
# try to drain other batches here. They will be refetched.
217
- raise Errors.CorruptRecordException("Invalid CRC")
+ raise Errors.CorruptRecordException(f"Invalid CRC - {tp}")
218
219
if self._isolation_level == READ_COMMITTED and \
220
next_batch.producer_id is not None:
0 commit comments