summaryrefslogtreecommitdiff
path: root/test/test_producer_integration.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@rd.io>2014-08-31 11:13:02 -0700
committerDana Powers <dana.powers@rd.io>2014-09-04 18:05:05 -0700
commitb99a9eee64aa9dec34f43085a551d076513b9f51 (patch)
tree91dbc62e3863897213af2fbd0070b92bff720e28 /test/test_producer_integration.py
parent404c56a55d95783a027313ae69d43097ceb18ab6 (diff)
downloadkafka-python-b99a9eee64aa9dec34f43085a551d076513b9f51.tar.gz
Import cleanups in tests
Diffstat (limited to 'test/test_producer_integration.py')
-rw-r--r--test/test_producer_integration.py15
1 files changed, 11 insertions, 4 deletions
diff --git a/test/test_producer_integration.py b/test/test_producer_integration.py
index 7d3a180..edffa5e 100644
--- a/test/test_producer_integration.py
+++ b/test/test_producer_integration.py
@@ -2,11 +2,18 @@ import os
import time
import uuid
-from kafka import * # noqa
-from kafka.common import * # noqa
+from kafka import (
+ SimpleProducer, KeyedProducer,
+ create_message, create_gzip_message, create_snappy_message,
+ RoundRobinPartitioner, HashedPartitioner
+)
+from kafka.common import (
+ FetchRequest, ProduceRequest, UnknownTopicOrPartitionError
+)
from kafka.codec import has_gzip, has_snappy
-from fixtures import ZookeeperFixture, KafkaFixture
-from testutil import *
+
+from test.fixtures import ZookeeperFixture, KafkaFixture
+from test.testutil import KafkaIntegrationTestCase, kafka_versions
class TestKafkaProducerIntegration(KafkaIntegrationTestCase):
topic = 'produce_topic'