Rename kafka.protocol -> kafka.protocol.legacy
This commit is contained in:
6
kafka/protocol/__init__.py
Normal file
6
kafka/protocol/__init__.py
Normal file
@@ -0,0 +1,6 @@
|
|||||||
|
from legacy import (
|
||||||
|
create_message, create_gzip_message,
|
||||||
|
create_snappy_message, create_message_set,
|
||||||
|
CODEC_NONE, CODEC_GZIP, CODEC_SNAPPY, ALL_CODECS,
|
||||||
|
ATTRIBUTE_CODEC_MASK, KafkaProtocol,
|
||||||
|
)
|
||||||
Reference in New Issue
Block a user