diff options
| author | Mahendra M <mahendra.m@gmail.com> | 2013-06-03 20:23:04 +0530 |
|---|---|---|
| committer | Mahendra M <mahendra.m@gmail.com> | 2013-06-03 20:23:04 +0530 |
| commit | 437889d00bb7d50f0e8a8d1cfa4b1cdced1944db (patch) | |
| tree | b84edf5e9b05d014d01ab4abd5051d775c3c7034 /kafka/conn.py | |
| parent | 58288d9f86a67772326cf946d0ff4729a764ad52 (diff) | |
| download | kafka-python-437889d00bb7d50f0e8a8d1cfa4b1cdced1944db.tar.gz | |
Fix auto-commit issues with multi-threading
Diffstat (limited to 'kafka/conn.py')
| -rw-r--r-- | kafka/conn.py | 3 |
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 |