diff options
| author | Dana Powers <dana.powers@gmail.com> | 2017-03-09 11:08:48 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2017-03-14 13:30:35 -0700 |
| commit | 3b899decb8b5159c1086a5211eda315c090c6d59 (patch) | |
| tree | c1c17671d13466c39f4414203f84bee4e387e4e5 | |
| parent | e775e05d652bc444eff5b1905066d272dea351a8 (diff) | |
| download | kafka-python-3b899decb8b5159c1086a5211eda315c090c6d59.tar.gz | |
Free lz4 decompression context to avoid leak
| -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. |