From 5d8d5412e576c5514497be3809ea899378f40e56 Mon Sep 17 00:00:00 2001 From: tpalino Date: Wed, 1 Jul 2015 22:47:02 -0700 Subject: Add missing import for ConsumerMetadataResponse --- test/test_protocol.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'test/test_protocol.py') 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, -- cgit v1.2.1