Add DeprecationWarnings to legacy KafkaClient, Simple/MultiProcess/Consumer, and KafkaConnectiondeprecation_warnings

1 files changed, 5 insertions, 0 deletions

diff --git a/kafka/consumer/multiprocess.py b/kafka/consumer/multiprocess.py
index 9358b09..fddb269 100644
--- a/kafka/consumer/multiprocess.py
+++ b/kafka/consumer/multiprocess.py
@@ -4,6 +4,7 @@ from collections import namedtuple
 import logging
 from multiprocessing import Process, Manager as MPManager
 import time
+import warnings
 
 from six.moves import queue
 
@@ -135,6 +136,10 @@ class MultiProcessConsumer(Consumer):
                  partitions_per_proc=0,
                  **simple_consumer_options):
 
+        warnings.warn('This class has been deprecated and will be removed in a'
+                      ' future release. Use KafkaConsumer instead',
+                      DeprecationWarning)
+
         # Initiate the base consumer class
         super(MultiProcessConsumer, self).__init__(
             client, group, topic,