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/consumer/base.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/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 |