A few fixes for offset APIs in 0.8.1

Author: mumrah

kafka/client.py

@@ -231,7 +231,7 @@ def send_offset_commit_request(self, group, payloads=[], fail_on_error=True, cal
 
     def send_offset_fetch_request(self, group, payloads=[], fail_on_error=True, callback=None):
         resps = self._send_broker_aware_request(payloads,
-                                   partial(KafkaProtocol.encode_offset_commit_fetch, group=group),
+                                   partial(KafkaProtocol.encode_offset_fetch_request, group=group),
                                    KafkaProtocol.decode_offset_fetch_response)
         out = []
         for resp in resps:

kafka/protocol.py

@@ -354,7 +354,6 @@ def decode_offset_commit_response(cls, data):
         ======
         data: bytes to decode
         """
-        data = data[2:] # TODO remove me when versionId is removed
         ((correlation_id,), cur) = relative_unpack('>i', data, 0)
         (client_id, cur) = read_short_string(data, cur)
         ((num_topics,), cur) = relative_unpack('>i', data, cur)
@@ -398,7 +397,6 @@ def decode_offset_fetch_response(cls, data):
         data: bytes to decode
         """
 
-        data = data[2:] # TODO remove me when versionId is removed
         ((correlation_id,), cur) = relative_unpack('>i', data, 0)
         (client_id, cur) = read_short_string(data, cur)
         ((num_topics,), cur) = relative_unpack('>i', data, cur)