summaryrefslogtreecommitdiff
path: root/kafka/conn.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2016-09-20 17:03:38 -0700
committerDana Powers <dana.powers@gmail.com>2016-12-17 10:13:03 -0800
commit07e09c1c2ec6787fc7e4f3c2578d31b4a15d20bc (patch)
treed11ea782a8ebd2f32a1b3a2d4cab55669ed46838 /kafka/conn.py
parent7690b1ab32b50ce3798c310648e7b69e46fafdbd (diff)
downloadkafka-python-07e09c1c2ec6787fc7e4f3c2578d31b4a15d20bc.tar.gz
Fixup doc references to max_in_flight_requests_per_connection
Diffstat (limited to 'kafka/conn.py')
-rw-r--r--kafka/conn.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/conn.py b/kafka/conn.py
index bbac554..247cff6 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -557,7 +557,7 @@ class BrokerConnection(object):
return future
def can_send_more(self):
- """Return True unless there are max_in_flight_requests."""
+ """Return True unless there are max_in_flight_requests_per_connection."""
max_ifrs = self.config['max_in_flight_requests_per_connection']
return len(self.in_flight_requests) < max_ifrs