summaryrefslogtreecommitdiff
path: root/test/test_producer.py
diff options
context:
space:
mode:
Diffstat (limited to 'test/test_producer.py')
-rw-r--r--test/test_producer.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/test/test_producer.py b/test/test_producer.py
index 1375525..caf8fe3 100644
--- a/test/test_producer.py
+++ b/test/test_producer.py
@@ -5,7 +5,7 @@ import logging
from mock import MagicMock
from . import unittest
-from kafka.producer import Producer
+from kafka.producer.base import Producer
class TestKafkaProducer(unittest.TestCase):
def test_producer_message_types(self):