openstack/deb-python-kafka
Code Issues Proposed changes

Merge pull request #98 from waliaashish85/dev

Browse Source 
Changes for aligning code with offset fetch and commit APIs (Kafka 0.8.1)
This commit is contained in:
Omar
2014-01-16 12:51:41 -08:00
parent fb4903e518 daabc9f28d
commit e6c43d15e6
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
kafka/protocol.py
View File

@@ -29,8 +29,8 @@ class KafkaProtocol(object):
FETCH_KEY = 1 FETCH_KEY = 1
OFFSET_KEY = 2 OFFSET_KEY = 2
METADATA_KEY = 3 METADATA_KEY = 3
OFFSET_COMMIT_KEY = 6 OFFSET_COMMIT_KEY = 8
OFFSET_FETCH_KEY = 7 OFFSET_FETCH_KEY = 9
ATTRIBUTE_CODEC_MASK = 0x03 ATTRIBUTE_CODEC_MASK = 0x03
CODEC_NONE = 0x00 CODEC_NONE = 0x00
@@ -451,7 +451,6 @@ class KafkaProtocol(object):
data: bytes to decode data: bytes to decode
""" """
((correlation_id,), cur) = relative_unpack('>i', data, 0) ((correlation_id,), cur) = relative_unpack('>i', data, 0)
(client_id, cur) = read_short_string(data, cur)
((num_topics,), cur) = relative_unpack('>i', data, cur) ((num_topics,), cur) = relative_unpack('>i', data, cur)
for i in xrange(num_topics): for i in xrange(num_topics):
@@ -502,7 +501,6 @@ class KafkaProtocol(object):
""" """
((correlation_id,), cur) = relative_unpack('>i', data, 0) ((correlation_id,), cur) = relative_unpack('>i', data, 0)
(client_id, cur) = read_short_string(data, cur)
((num_topics,), cur) = relative_unpack('>i', data, cur) ((num_topics,), cur) = relative_unpack('>i', data, cur)
for i in range(num_topics): for i in range(num_topics):