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 e775e05 commit 3b899deCopy full SHA for 3b899de
kafka/codec.py
@@ -192,6 +192,7 @@ def lz4_decode(payload):
192
# pylint: disable-msg=no-member
193
ctx = lz4f.createDecompContext()
194
data = lz4f.decompressFrame(payload, ctx)
195
+ lz4f.freeDecompContext(ctx)
196
197
# lz4f python module does not expose how much of the payload was
198
# actually read if the decompression was only partial.
0 commit comments