diff options
| author | tpalino <tpalino@linkedin.com> | 2015-07-01 22:47:02 -0700 |
|---|---|---|
| committer | tpalino <tpalino@linkedin.com> | 2015-07-01 22:47:02 -0700 |
| commit | 5d8d5412e576c5514497be3809ea899378f40e56 (patch) | |
| tree | 1607f2cd2e147b17f48e1a1f7a3d03abb36f3654 | |
| parent | c01963682e1ec16dbde9b55cda4ec95ad2346476 (diff) | |
| download | kafka-python-5d8d5412e576c5514497be3809ea899378f40e56.tar.gz | |
Add missing import for ConsumerMetadataResponse
| -rw-r--r-- | test/test_protocol.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/test/test_protocol.py b/test/test_protocol.py index 1f967f2..f5bc289 100644 --- a/test/test_protocol.py +++ b/test/test_protocol.py @@ -13,7 +13,7 @@ from kafka.common import ( ProduceResponse, FetchResponse, OffsetAndMessage, BrokerMetadata, TopicMetadata, PartitionMetadata, TopicAndPartition, KafkaUnavailableError, UnsupportedCodecError, ConsumerFetchSizeTooSmall, - ProtocolError + ProtocolError, ConsumerMetadataResponse ) from kafka.protocol import ( ATTRIBUTE_CODEC_MASK, CODEC_NONE, CODEC_GZIP, CODEC_SNAPPY, KafkaProtocol, |