diff options
Diffstat (limited to 'kafka/protocol.py')
| -rw-r--r-- | kafka/protocol.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/protocol.py b/kafka/protocol.py index ca21db3..fc866ad 100644 --- a/kafka/protocol.py +++ b/kafka/protocol.py @@ -217,7 +217,7 @@ class KafkaProtocol(object): return struct.pack('>i%ds' % len(message), len(message), message) @classmethod - def decode_fetch_response_iter(cls, data): + def decode_fetch_response(cls, data): """ Decode bytes to a FetchResponse |