From 90c729438a2e3f1b194e58231e41bd16bd7b7172 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Tue, 5 Apr 2016 22:54:28 -0700 Subject: Use version-indexed lists for request/response protocol structs --- kafka/conn.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'kafka/conn.py') diff --git a/kafka/conn.py b/kafka/conn.py index dc7dd23..014b340 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -321,7 +321,7 @@ class BrokerConnection(object): # 0.8.2 quirk if (self.config['api_version'] == (0, 8, 2) and - ifr.response_type is GroupCoordinatorResponse and + ifr.response_type is GroupCoordinatorResponse[0] and ifr.correlation_id != 0 and recv_correlation_id == 0): log.warning('Kafka 0.8.2 quirk -- GroupCoordinatorResponse' -- cgit v1.2.1