summaryrefslogtreecommitdiff
path: root/kafka/conn.py
diff options
context:
space:
mode:
Diffstat (limited to 'kafka/conn.py')
-rw-r--r--kafka/conn.py2
1 files changed, 2 insertions, 0 deletions
diff --git a/kafka/conn.py b/kafka/conn.py
index 7103253..00c4ce2 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -3,8 +3,10 @@ import socket
import struct
from threading import local
+
log = logging.getLogger("kafka")
+
class KafkaConnection(local):
"""
A socket connection to a single Kafka broker