diff options
Diffstat (limited to 'kafka/client.py')
| -rw-r--r-- | kafka/client.py | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/kafka/client.py b/kafka/client.py index 14e71bb..a517997 100644 --- a/kafka/client.py +++ b/kafka/client.py @@ -19,11 +19,17 @@ from kafka.conn import ( ConnectionStates) from kafka.protocol import KafkaProtocol +# New KafkaClient +# this is not exposed in top-level imports yet, +# due to conflicts with legacy SimpleConsumer / SimpleProducer usage +from kafka.client_async import KafkaClient + log = logging.getLogger(__name__) -class KafkaClient(object): +# Legacy KafkaClient interface -- will be deprecated soon +class SimpleClient(object): CLIENT_ID = b'kafka-python' |