diff options
| author | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-02-25 15:18:16 +0300 |
|---|---|---|
| committer | Viktor Shlapakov <vshlapakov@gmail.com> | 2015-06-03 11:22:47 +0300 |
| commit | 81d868869fa2f7ab980df5477d82654dc2598356 (patch) | |
| tree | 6159da26246800cf2724f9c2aef139eb4612aca6 | |
| parent | b82f94f5a409a237222a6486a870751fa17da254 (diff) | |
| download | kafka-python-81d868869fa2f7ab980df5477d82654dc2598356.tar.gz | |
Fixed base producer imports
| -rw-r--r-- | kafka/producer/base.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/kafka/producer/base.py b/kafka/producer/base.py index a5af3d6..34b1d04 100644 --- a/kafka/producer/base.py +++ b/kafka/producer/base.py @@ -15,7 +15,8 @@ from threading import Thread, Event import six from kafka.common import ( - ProduceRequest, TopicAndPartition, UnsupportedCodecError + ProduceRequest, TopicAndPartition, + UnsupportedCodecError, FailedPayloadsError ) from kafka.protocol import CODEC_NONE, ALL_CODECS, create_message_set from kafka.util import kafka_bytestring |