diff options
author | Ivan Pouzyrevsky <sandello@yandex-team.ru> | 2013-06-02 01:26:14 +0400 |
---|---|---|
committer | David Arthur <mumrah@gmail.com> | 2013-06-07 21:20:55 -0400 |
commit | e073b3310d0b29ac4c7cfd0c9b73ffa346f5ba74 (patch) | |
tree | bde4e20aaddfe743467511996fa81cae425bb691 /kafka/codec.py | |
parent | 6704050e50a2934806e349ac875f2ab31ccfcd9d (diff) | |
download | kafka-python-e073b3310d0b29ac4c7cfd0c9b73ffa346f5ba74.tar.gz |
Refactor and update integration tests
Diffstat (limited to 'kafka/codec.py')
-rw-r--r-- | kafka/codec.py | 7 |
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() |