THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
MessageAndOffset => Offset MessageSize Message Offset => int64 MessageSize => int32 Message => Crc MagicByte Attributes Timestamp KeyLength Key ValueLength Value Crc => int32 MagicByte => int8 <---------------------- Bump up magic byte to 2 Attributes => int8 Timestamp => int64 KeyLength => int32 Key => bytes HeadersFlag => byte <-------------------------------- NEW headers flag 0 if no headers or old message, or 1 if headers (optional) HeadersLength => int32 <------------------ NEW [optional] length of the byte[] of the serialized headers (int32 = 0 if no headers) (optional) Headers => bytes <------------------------ NEW [optional] serialized form of the headers Map<String, String> (if old message or no headers this can empty) ValueLength => int32 Value => bytes |
...