Add comment about no server response case in _send_broker_aware_request
This commit is contained in:
@@ -178,8 +178,13 @@ class KafkaClient(object):
|
|||||||
# Send the request, recv the response
|
# Send the request, recv the response
|
||||||
try:
|
try:
|
||||||
conn.send(requestId, request)
|
conn.send(requestId, request)
|
||||||
|
|
||||||
|
# decoder_fn=None signal that the server is expected to not
|
||||||
|
# send a response. This probably only applies to
|
||||||
|
# ProduceRequest w/ acks = 0
|
||||||
if decoder_fn is None:
|
if decoder_fn is None:
|
||||||
continue
|
continue
|
||||||
|
|
||||||
try:
|
try:
|
||||||
response = conn.recv(requestId)
|
response = conn.recv(requestId)
|
||||||
except ConnectionError as e:
|
except ConnectionError as e:
|
||||||
|
|||||||
Reference in New Issue
Block a user