From 0ab97a99088c2871c3ab30dbc0dbf13f5f414433 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Fri, 4 Dec 2015 18:02:22 -0800 Subject: Fix requestId handling in send_broker_aware_request --- kafka/client.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'kafka/client.py') diff --git a/kafka/client.py b/kafka/client.py index 810fa46..b3dcf51 100644 --- a/kafka/client.py +++ b/kafka/client.py @@ -236,13 +236,13 @@ class KafkaClient(object): responses[topic_partition] = None continue else: - connections_by_socket[conn.get_connected_socket()] = (conn, broker) + connections_by_socket[conn.get_connected_socket()] = (conn, broker, requestId) conn = None while connections_by_socket: sockets = connections_by_socket.keys() rlist, _, _ = select.select(sockets, [], [], None) - conn, broker = connections_by_socket.pop(rlist[0]) + conn, broker, requestId = connections_by_socket.pop(rlist[0]) try: response = conn.recv(requestId) except ConnectionError as e: -- cgit v1.2.1