From 4079a582b07989e683bcb2d87f6d522ed61a4f66 Mon Sep 17 00:00:00 2001
From: Dana Powers <dana.powers@rd.io>
Date: Tue, 12 Jan 2016 16:52:30 -0800
Subject: Add DeprecationWarnings to legacy KafkaClient,
 Simple/MultiProcess/Consumer, and KafkaConnection

---
 kafka/consumer/base.py | 4 ++++
 1 file changed, 4 insertions(+)

(limited to 'kafka/consumer/base.py')

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
-- 
cgit v1.2.1