diff options
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 ffc839e..dc7dd23 100644 --- a/kafka/conn.py +++ b/kafka/conn.py @@ -13,7 +13,7 @@ import warnings import six -import kafka.common as Errors +import kafka.errors as Errors from kafka.future import Future from kafka.protocol.api import RequestHeader from kafka.protocol.commit import GroupCoordinatorResponse @@ -149,7 +149,7 @@ class BrokerConnection(object): Arguments: error (Exception, optional): pending in-flight-requests will be failed with this exception. - Default: kafka.common.ConnectionError. + Default: kafka.errors.ConnectionError. """ if self._sock: self._sock.close() |