summaryrefslogtreecommitdiff
path: root/test/test_failover_integration.py
diff options
context:
space:
mode:
authorDana Powers <dana.powers@gmail.com>2014-09-10 23:31:33 -0700
committerDana Powers <dana.powers@gmail.com>2014-09-10 23:31:33 -0700
commit931670ff2d13e1e4953bbcfa4fff45d7dcb94533 (patch)
tree46a3873a5d9d653e09aaf5c7b5fc60167ea22a8c /test/test_failover_integration.py
parent04dbd0e7912c43e0d5cf32b29f0250dc67937df7 (diff)
parent27e812e66bd04d3acf59ad6792b07d1c7056c036 (diff)
downloadkafka-python-931670ff2d13e1e4953bbcfa4fff45d7dcb94533.tar.gz
Merge pull request #232 from dpkp/directory_layout
Separate Consumer/Producer/Partitioner modules
Diffstat (limited to 'test/test_failover_integration.py')
-rw-r--r--test/test_failover_integration.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/test/test_failover_integration.py b/test/test_failover_integration.py
index b572b4e..d307d41 100644
--- a/test/test_failover_integration.py
+++ b/test/test_failover_integration.py
@@ -6,7 +6,7 @@ from . import unittest
from kafka import KafkaClient, SimpleConsumer
from kafka.common import TopicAndPartition, FailedPayloadsError, ConnectionError
-from kafka.producer import Producer
+from kafka.producer.base import Producer
from test.fixtures import ZookeeperFixture, KafkaFixture
from test.testutil import (