diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-06-04 13:24:45 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-06-06 19:27:55 -0700 |
| commit | 68f5506c20d936257f3c11aa12cb692c8c732ed0 (patch) | |
| tree | 2a208ac9b5bdd33e77048d81ee462fb40102bdec | |
| parent | 87bea900df341ddc2431569bdc329d069b6c5c61 (diff) | |
| download | kafka-python-68f5506c20d936257f3c11aa12cb692c8c732ed0.tar.gz | |
PR 331 fixup: Fix kafka.common imports from kafka.producer.base (one import block, add ProduceResponse)
| -rw-r--r-- | kafka/producer/base.py | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/kafka/producer/base.py b/kafka/producer/base.py index 5cbc521..2542df5 100644 --- a/kafka/producer/base.py +++ b/kafka/producer/base.py @@ -17,10 +17,9 @@ import six from kafka.common import ( ProduceRequest, ProduceResponse, TopicAndPartition, RetryOptions, kafka_errors, UnsupportedCodecError, FailedPayloadsError, - RequestTimedOutError, AsyncProducerQueueFull, UnknownError + RequestTimedOutError, AsyncProducerQueueFull, UnknownError, + RETRY_ERROR_TYPES, RETRY_BACKOFF_ERROR_TYPES, RETRY_REFRESH_ERROR_TYPES ) -from kafka.common import ( - RETRY_ERROR_TYPES, RETRY_BACKOFF_ERROR_TYPES, RETRY_REFRESH_ERROR_TYPES) from kafka.protocol import CODEC_NONE, ALL_CODECS, create_message_set from kafka.util import kafka_bytestring |