You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Currently, in aiokafka.record.default_records._DefaultRecordBatchPy._maybe_uncompress it doesn't handle any compression type that is not supported. So if, for example, a record is consumed that is compressed with zstd, you will only get following error message:
UnboundLocalError: local variable 'uncompressed' referenced before assignment
It would be good with a more informative error message here, informing the user than an unsupported compression type was used.
The text was updated successfully, but these errors were encountered:
Currently, in
aiokafka.record.default_records._DefaultRecordBatchPy._maybe_uncompress
it doesn't handle any compression type that is not supported. So if, for example, a record is consumed that is compressed with zstd, you will only get following error message:UnboundLocalError: local variable 'uncompressed' referenced before assignment
It would be good with a more informative error message here, informing the user than an unsupported compression type was used.
The text was updated successfully, but these errors were encountered: