openstack/deb-python-kafka
Code Issues Proposed changes

Deleting client_id from offset commit and fetch response as per Kafka trunk code

Browse Source
This commit is contained in:
Ashish Walia
2014-01-07 12:30:52 -05:00
parent 55816493c7
commit daabc9f28d
1 changed files with 0 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
kafka/protocol.py
View File

@@ -439,7 +439,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):
@@ -490,7 +489,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):