diff options
| -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 |