summaryrefslogtreecommitdiff
path: root/kafka/conn.py
diff options
context:
space:
mode:
Diffstat (limited to 'kafka/conn.py')
-rw-r--r--kafka/conn.py1
1 files changed, 1 insertions, 0 deletions
diff --git a/kafka/conn.py b/kafka/conn.py
index 7798a75..29efbf1 100644
--- a/kafka/conn.py
+++ b/kafka/conn.py
@@ -17,6 +17,7 @@ class KafkaConnection(local):
since the Kafka API includes a correlation id.
"""
def __init__(self, host, port, bufsize=4096):
+ super(KafkaConnection, self).__init__()
self.host = host
self.port = port
self.bufsize = bufsize