Fix more tests, only multiprocessing consumer ones remaining

1 files changed, 4 insertions, 0 deletions

diff --git a/kafka/conn.py b/kafka/conn.py
index 41cd424..aef0299 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -155,6 +155,10 @@ class KafkaConnection(local):
         return a new KafkaConnection object
         """
         c = copy.deepcopy(self)
+        # Python 3 doesn't copy custom attributes of the threadlocal subclass
+        c.host = copy.copy(self.host)
+        c.port = copy.copy(self.port)
+        c.timeout = copy.copy(self.timeout)
         c._sock = None
         return c