openstack/deb-python-kafka
Code Issues Proposed changes

Added keys to compressed messages (both gzip and snappy).

Browse Source
This commit is contained in:
Eric Hewitt
2015-01-02 11:34:38 -05:00
parent 9c5216a97f
commit 6603088f0a
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
kafka/protocol.py
View File

@@ -568,7 +568,7 @@ def create_gzip_message(payloads, key=None):
key: bytes, a key used for partition routing (optional) key: bytes, a key used for partition routing (optional)
""" """
message_set = KafkaProtocol._encode_message_set( message_set = KafkaProtocol._encode_message_set(
[create_message(payload) for payload in payloads]) [create_message(payload, key) for payload in payloads])
gzipped = gzip_encode(message_set) gzipped = gzip_encode(message_set)
codec = ATTRIBUTE_CODEC_MASK & CODEC_GZIP codec = ATTRIBUTE_CODEC_MASK & CODEC_GZIP
@@ -589,7 +589,7 @@ def create_snappy_message(payloads, key=None):
key: bytes, a key used for partition routing (optional) key: bytes, a key used for partition routing (optional)
""" """
message_set = KafkaProtocol._encode_message_set( message_set = KafkaProtocol._encode_message_set(
[create_message(payload) for payload in payloads]) [create_message(payload, key) for payload in payloads])
snapped = snappy_encode(message_set) snapped = snappy_encode(message_set)
codec = ATTRIBUTE_CODEC_MASK & CODEC_SNAPPY codec = ATTRIBUTE_CODEC_MASK & CODEC_SNAPPY