test_client_async

Author: dpkp

test/test_client_async.py

@@ -10,7 +10,7 @@
 import kafka.errors as Errors
 from kafka.future import Future
 from kafka.protocol.new.metadata import MetadataRequest
-from kafka.protocol.produce import ProduceRequest
+from kafka.protocol.new.producer import ProduceRequest
 from kafka.structs import BrokerMetadata