Fix import error in kafka/producer/base.py

This commit is contained in:
Dana Powers
2015-06-06 10:24:39 -07:00
parent cef5cb572e
commit 6406747f37

View File

@@ -15,7 +15,7 @@ from threading import Thread, Event
import six
from kafka.common import (
ProduceRequest, TopicAndPartition, RetryOptions,
ProduceRequest, ProduceResponse, TopicAndPartition, RetryOptions,
kafka_errors, UnsupportedCodecError, FailedPayloadsError,
RequestTimedOutError, AsyncProducerQueueFull, UnknownError
)