From 4079a582b07989e683bcb2d87f6d522ed61a4f66 Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Tue, 12 Jan 2016 16:52:30 -0800 Subject: Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, and KafkaConnection --- kafka/client.py | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) (limited to 'kafka/client.py') 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' -- cgit v1.2.1