summaryrefslogtreecommitdiff
path: root/test/integration.py
diff options
context:
space:
mode:
authorDavid Arthur <mumrah@gmail.com>2012-10-02 12:09:19 -0400
committerDavid Arthur <mumrah@gmail.com>2012-10-02 12:09:19 -0400
commit36b67b79202f8bdeab60de1f4ed582328eeb04db (patch)
treea907573f3c223cb8b225d734f6b475b9359affc3 /test/integration.py
parent036af5b997749320a1dd6da5c48c5120e6691365 (diff)
downloadkafka-python-36b67b79202f8bdeab60de1f4ed582328eeb04db.tar.gz
Start work on packaging issue #3
Diffstat (limited to 'test/integration.py')
-rw-r--r--test/integration.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/test/integration.py b/test/integration.py
index fccf28f..197f5ec 100644
--- a/test/integration.py
+++ b/test/integration.py
@@ -11,7 +11,7 @@ from threading import Thread, Event
import time
import unittest
-from kafka import KafkaClient, ProduceRequest, FetchRequest
+from kafka.kafka import KafkaClient, ProduceRequest, FetchRequest
def get_open_port():
sock = socket.socket()