diff options
author | Dana Powers <dana.powers@rd.io> | 2014-09-01 17:24:50 -0700 |
---|---|---|
committer | Dana Powers <dana.powers@rd.io> | 2014-09-04 18:05:05 -0700 |
commit | 1b282d21522d101f4129d5fc3e70e2b904d3b171 (patch) | |
tree | d559e3c3f650dab1ce9247aa7a89f41bdd410e46 /test/test_protocol.py | |
parent | b0f85932216ddd4083b67a5e0595636f4d7b25ce (diff) | |
download | kafka-python-1b282d21522d101f4129d5fc3e70e2b904d3b171.tar.gz |
Cleanup tests: no more import *; remove unused
Diffstat (limited to 'test/test_protocol.py')
-rw-r--r-- | test/test_protocol.py | 9 |
1 files changed, 2 insertions, 7 deletions
diff --git a/test/test_protocol.py b/test/test_protocol.py index b1c5201..f6e3c96 100644 --- a/test/test_protocol.py +++ b/test/test_protocol.py @@ -4,20 +4,15 @@ import struct import unittest2 from mock import patch, sentinel -from kafka import KafkaClient from kafka.common import ( OffsetRequest, OffsetCommitRequest, OffsetFetchRequest, OffsetResponse, OffsetCommitResponse, OffsetFetchResponse, ProduceRequest, FetchRequest, Message, ChecksumError, ConsumerFetchSizeTooSmall, ProduceResponse, FetchResponse, OffsetAndMessage, - BrokerMetadata, PartitionMetadata, TopicAndPartition, KafkaUnavailableError, - ProtocolError, LeaderUnavailableError, PartitionUnavailableError, + BrokerMetadata, PartitionMetadata, ProtocolError, UnsupportedCodecError ) -from kafka.codec import ( - has_snappy, gzip_encode, gzip_decode, - snappy_encode, snappy_decode -) +from kafka.codec import has_snappy, gzip_decode, snappy_decode import kafka.protocol from kafka.protocol import ( ATTRIBUTE_CODEC_MASK, CODEC_NONE, CODEC_GZIP, CODEC_SNAPPY, KafkaProtocol, |