diff options
Diffstat (limited to 'test/test_consumer.py')
| -rw-r--r-- | test/test_consumer.py | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/test/test_consumer.py b/test/test_consumer.py index 778d76a..f0b4e53 100644 --- a/test/test_consumer.py +++ b/test/test_consumer.py @@ -9,8 +9,7 @@ from kafka import KafkaClient from kafka.consumer import SimpleConsumer from kafka.common import ( ProduceRequest, BrokerMetadata, PartitionMetadata, - TopicAndPartition, KafkaUnavailableError, - LeaderUnavailableError, PartitionUnavailableError + TopicAndPartition, PartitionUnavailableError ) from kafka.protocol import ( create_message, KafkaProtocol |