Add missing import for ConsumerMetadataResponse

tpalino · tpalino · commit 5d8d5412e576 · 2015-07-01T22:47:02.000-07:00
diff --git a/test/test_protocol.py b/test/test_protocol.py
@@ -13,7 +13,7 @@
     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,

Original file line number	Diff line number	Diff line change
`@@ -13,7 +13,7 @@`
`13`	`13`	`ProduceResponse, FetchResponse, OffsetAndMessage,`
`14`	`14`	`BrokerMetadata, TopicMetadata, PartitionMetadata, TopicAndPartition,`
`15`	`15`	`KafkaUnavailableError, UnsupportedCodecError, ConsumerFetchSizeTooSmall,`
`16`		`- ProtocolError`
	`16`	`+ ProtocolError, ConsumerMetadataResponse`
`17`	`17`	`)`
`18`	`18`	`from kafka.protocol import (`
`19`	`19`	`ATTRIBUTE_CODEC_MASK, CODEC_NONE, CODEC_GZIP, CODEC_SNAPPY, KafkaProtocol,`