diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-01-12 22:57:24 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-01-12 22:57:24 -0800 |
| commit | 1f6be11b0948cfaf27e88c2914b04a680a48f926 (patch) | |
| tree | 861bd740fa19daaaedf7e921bc9166529c88192d /kafka/client.py | |
| parent | 22f84bfb78cee4d059af7d8771535ad5fa270e30 (diff) | |
| parent | 4079a582b07989e683bcb2d87f6d522ed61a4f66 (diff) | |
| download | kafka-python-1f6be11b0948cfaf27e88c2914b04a680a48f926.tar.gz | |
Merge pull request #507 from dpkp/deprecation_warnings
Add DeprecationWarnings to legacy classes
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' |