diff options
| -rw-r--r-- | kafka/codec.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/kafka/codec.py b/kafka/codec.py index 1e57107..4deec49 100644 --- a/kafka/codec.py +++ b/kafka/codec.py @@ -192,6 +192,7 @@ def lz4_decode(payload): # pylint: disable-msg=no-member ctx = lz4f.createDecompContext() data = lz4f.decompressFrame(payload, ctx) + lz4f.freeDecompContext(ctx) # lz4f python module does not expose how much of the payload was # actually read if the decompression was only partial. |