summaryrefslogtreecommitdiff
path: root/test/test_failover_integration.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@rd.io>2015-06-08 21:26:58 -0700
committerDana Powers <dana.powers@rd.io>2015-06-08 21:26:58 -0700
commit712377ab15ae7c1c0b031df310d60235b7c57cae (patch)
treea592f63bb45b7b16d6c5474d6cf9e4a5153f7e75 /test/test_failover_integration.py
parentffcb49d71a5ef1871a2631216db5198bbf8a7b41 (diff)
downloadkafka-python-712377ab15ae7c1c0b031df310d60235b7c57cae.tar.gz
Import style nits in integration tests
Diffstat (limited to 'test/test_failover_integration.py')
-rw-r--r--test/test_failover_integration.py3
1 files changed, 1 insertions, 2 deletions
diff --git a/test/test_failover_integration.py b/test/test_failover_integration.py
index 1d835e2..5082d7c 100644
--- a/test/test_failover_integration.py
+++ b/test/test_failover_integration.py
@@ -4,10 +4,9 @@ import time
from . import unittest
-from kafka import KafkaClient, SimpleConsumer
+from kafka import KafkaClient, SimpleConsumer, KeyedProducer
from kafka.common import TopicAndPartition, FailedPayloadsError, ConnectionError
from kafka.producer.base import Producer
-from kafka.producer import KeyedProducer
from kafka.util import kafka_bytestring
from test.fixtures import ZookeeperFixture, KafkaFixture