diff options
author | Dana Powers <dana.powers@gmail.com> | 2016-11-14 11:01:34 -0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2016-11-14 11:01:34 -0800 |
commit | 8ac79fbe3dd1b28d052551a5fa3e6acfdc1ba457 (patch) | |
tree | bc430da90685195db6532311f37781ac734479e5 /kafka/conn.py | |
parent | 77591afa789a4752f4d385228bea980f448f6a08 (diff) | |
parent | cd74c1fe4053385151175b5100cb0a0d43bc31f6 (diff) | |
download | kafka-python-8ac79fbe3dd1b28d052551a5fa3e6acfdc1ba457.tar.gz |
Fix typos (#874)
Diffstat (limited to 'kafka/conn.py')
-rw-r--r-- | kafka/conn.py | 4 |
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 ? |