diff options
| author | Dana Powers <dana.powers@rd.io> | 2016-01-23 15:19:55 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2016-01-24 13:26:42 -0800 |
| commit | ee19cbfa4ae92e5fbe41d7ac6e9c199b49c39a88 (patch) | |
| tree | 3ab1ff852374bba62b2001e898d4cde8adcdfcea | |
| parent | 48e96822b3ec4f897438a2d1cdb735f51648cb48 (diff) | |
| download | kafka-python-ee19cbfa4ae92e5fbe41d7ac6e9c199b49c39a88.tar.gz | |
Add Message and MessageSet HEADER_SIZE bytes
| -rw-r--r-- | kafka/protocol/message.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/kafka/protocol/message.py b/kafka/protocol/message.py index 2648e24..dffb1bb 100644 --- a/kafka/protocol/message.py +++ b/kafka/protocol/message.py @@ -20,6 +20,7 @@ class Message(Struct): CODEC_MASK = 0x03 CODEC_GZIP = 0x01 CODEC_SNAPPY = 0x02 + HEADER_SIZE = 14 # crc(4), magic(1), attributes(1), key+value size(4*2) def __init__(self, value, key=None, magic=0, attributes=0, crc=0): assert value is None or isinstance(value, bytes), 'value must be bytes' @@ -83,6 +84,7 @@ class MessageSet(AbstractType): ('message_size', Int32), ('message', Message.SCHEMA) ) + HEADER_SIZE = 12 # offset + message_size @classmethod def encode(cls, items, size=True, recalc_message_size=True): |