From 3b899decb8b5159c1086a5211eda315c090c6d59 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Thu, 9 Mar 2017 11:08:48 -0800 Subject: Free lz4 decompression context to avoid leak --- kafka/codec.py | 1 + 1 file changed, 1 insertion(+) 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. -- cgit v1.2.1