Fix auto-commit issues with multi-threading

1 files changed, 2 insertions, 1 deletions

diff --git a/kafka/conn.py b/kafka/conn.py
index 15ce6ee..fce1fdc 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -1,10 +1,11 @@
 import logging
 import socket
 import struct
+from threading import local
 
 log = logging.getLogger("kafka")
 
-class KafkaConnection(object):
+class KafkaConnection(local):
     """
     A socket connection to a single Kafka broker