diff options
Diffstat (limited to 'kafka/client_async.py')
| -rw-r--r-- | kafka/client_async.py | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/kafka/client_async.py b/kafka/client_async.py index d70e4f2..b77ead5 100644 --- a/kafka/client_async.py +++ b/kafka/client_async.py @@ -11,10 +11,9 @@ import time import six -import kafka.common as Errors # TODO: make Errors a separate class - from .cluster import ClusterMetadata from .conn import BrokerConnection, ConnectionStates, collect_hosts, get_ip_port_afi +from . import errors as Errors from .future import Future from .protocol.metadata import MetadataRequest from .protocol.produce import ProduceRequest |