From 0678a452ca7ad5fba8e947cbfcf8fcb0f87b902c Mon Sep 17 00:00:00 2001 From: David Arthur Date: Mon, 1 Apr 2013 14:56:59 -0400 Subject: Refactoring a bit, cleanup for 0.8 Marking some stuff as not compatible for 0.8 (will be added in 0.8.1) --- kafka/protocol.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'kafka/protocol.py') 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 -- cgit v1.2.1