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

1 files changed, 3 insertions, 0 deletions

diff --git a/kafka/conn.py b/kafka/conn.py
index 6ee5f5f..0c8d002 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -9,6 +9,7 @@ import socket
 import struct
 from threading import local
 import time
+import warnings
 
 import six
 
@@ -375,6 +376,8 @@ class KafkaConnection(local):
             in seconds. None means no timeout, so a request can block forever.
     """
     def __init__(self, host, port, timeout=DEFAULT_SOCKET_TIMEOUT_SECONDS):
+        warnings.warn('KafkaConnection has been deprecated and will be'
+                      ' removed in a future release', DeprecationWarning)
         super(KafkaConnection, self).__init__()
         self.host = host
         self.port = port