diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-12-04 18:02:22 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-12-04 18:02:22 -0800 |
| commit | 0ab97a99088c2871c3ab30dbc0dbf13f5f414433 (patch) | |
| tree | 9b1e0ef7f7aed2e321a50203fd9b98e1cc15bc4b | |
| parent | fb024355f07735d148c035dfd51b279d1b8e59df (diff) | |
| download | kafka-python-0ab97a99088c2871c3ab30dbc0dbf13f5f414433.tar.gz | |
Fix requestId handling in send_broker_aware_request
| -rw-r--r-- | kafka/client.py | 4 |
1 files changed, 2 insertions, 2 deletions
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: |