diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-12 16:52:30 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-12 16:52:30 -0800 |
| commit | 4079a582b07989e683bcb2d87f6d522ed61a4f66 (patch) | |
| tree | deba002c4b9ce6407fe8160afceccc25d9660b09 /kafka/client.py | |
| parent | dcad3fea16028ae00f64baa981553b62666b15fb (diff) | |
| download | kafka-python-deprecation_warnings.tar.gz | |
Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, and KafkaConnectiondeprecation_warnings
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' |