diff options
Diffstat (limited to 'kafka/consumer/base.py')
| -rw-r--r-- | kafka/consumer/base.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/kafka/consumer/base.py b/kafka/consumer/base.py index 2059d92..78f376e 100644 --- a/kafka/consumer/base.py +++ b/kafka/consumer/base.py @@ -4,6 +4,7 @@ import atexit import logging import numbers from threading import Lock +import warnings import kafka.common from kafka.common import ( @@ -46,6 +47,9 @@ class Consumer(object): auto_commit_every_n=AUTO_COMMIT_MSG_COUNT, auto_commit_every_t=AUTO_COMMIT_INTERVAL): + warnings.warn('deprecated -- this class will be removed in a future' + ' release. Use KafkaConsumer instead.', + DeprecationWarning) self.client = client self.topic = topic self.group = group |