summaryrefslogtreecommitdiff
path: root/kafka/codec.py
diff options
context:
space:
mode:
authorIvan Pouzyrevsky <sandello@yandex-team.ru>2013-06-02 01:26:14 +0400
committerDavid Arthur <mumrah@gmail.com>2013-06-07 21:20:55 -0400
commite073b3310d0b29ac4c7cfd0c9b73ffa346f5ba74 (patch)
treebde4e20aaddfe743467511996fa81cae425bb691 /kafka/codec.py
parent6704050e50a2934806e349ac875f2ab31ccfcd9d (diff)
downloadkafka-python-e073b3310d0b29ac4c7cfd0c9b73ffa346f5ba74.tar.gz
Refactor and update integration tests
Diffstat (limited to 'kafka/codec.py')
-rw-r--r--kafka/codec.py7
1 files changed, 7 insertions, 0 deletions
diff --git a/kafka/codec.py b/kafka/codec.py
index c7d3992..cb3858b 100644
--- a/kafka/codec.py
+++ b/kafka/codec.py
@@ -11,6 +11,13 @@ except ImportError:
log.warn("Snappy codec not available")
hasSnappy = False
+def has_gzip():
+ return True
+
+
+def has_snappy():
+ return hasSnappy
+
def gzip_encode(payload):
buf = StringIO()