summaryrefslogtreecommitdiff
path: root/kafka/conn.py
diff options
context:
space:
mode:
authorCarson Ip <carsonip@users.noreply.github.com>2019-07-14 23:22:10 +0800
committerDana Powers <dana.powers@gmail.com>2019-07-14 08:22:10 -0700
commiteed25fc36110b12ec370b4d0e332173abce9076f (patch)
tree735571279d443f339bad32d207dd8beeb6cbf2f0 /kafka/conn.py
parentfb87a353d99b3271105d0941f39ee64bf2ab6858 (diff)
downloadkafka-python-eed25fc36110b12ec370b4d0e332173abce9076f.tar.gz
Fix minor typo (#1865)
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 825406c..80ece87 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -912,7 +912,7 @@ class BrokerConnection(object):
self.config['request_timeout_ms']))
return ()
- # augment respones w/ correlation_id, future, and timestamp
+ # augment responses w/ correlation_id, future, and timestamp
for i, (correlation_id, response) in enumerate(responses):
try:
with self._lock: