summaryrefslogtreecommitdiff
path: root/kafka/conn.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2016-11-14 11:01:34 -0800
committerGitHub <noreply@github.com>2016-11-14 11:01:34 -0800
commit8ac79fbe3dd1b28d052551a5fa3e6acfdc1ba457 (patch)
treebc430da90685195db6532311f37781ac734479e5 /kafka/conn.py
parent77591afa789a4752f4d385228bea980f448f6a08 (diff)
parentcd74c1fe4053385151175b5100cb0a0d43bc31f6 (diff)
downloadkafka-python-8ac79fbe3dd1b28d052551a5fa3e6acfdc1ba457.tar.gz
Fix typos (#874)
Diffstat (limited to 'kafka/conn.py')
-rw-r--r--kafka/conn.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/kafka/conn.py b/kafka/conn.py
index 6af0d8f..9f5b3f0 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -140,7 +140,7 @@ class BrokerConnection(object):
api_version_auto_timeout_ms (int): number of milliseconds to throw a
timeout exception from the constructor when checking the broker
api version. Only applies if api_version is None
- state_chance_callback (callable): function to be called when the
+ state_change_callback (callable): function to be called when the
connection state changes from CONNECTING to CONNECTED etc.
metrics (kafka.metrics.Metrics): Optionally provide a metrics
instance for capturing network IO stats. Default: None.
@@ -291,7 +291,7 @@ class BrokerConnection(object):
' Disconnecting.', self, ret)
self.close()
- # Connection timedout
+ # Connection timed out
elif time.time() > request_timeout + self.last_attempt:
log.error('Connection attempt to %s timed out', self)
self.close() # error=TimeoutError ?