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 HeadersLength Headers ValueLength Value
Crc => int32
MagicByte => int8 <---------------------- Bump up magic byte to 2
Attributes => int8
Timestamp => int64
KeyLength => int32
Key => bytes
HeadersLength => int32 <------------------ NEW 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
|
...
Code Block | ||
---|---|---|
| ||
MessageAndOffset => Offset MessageSize Message
Offset => int64
MessageSize => int32
Message => Crc MagicByte Attributes Timestamp KeyLength Key HeadersFlag HeadersLength Headers 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 if headers
(optional) Headers => bytes <------------------------ NEW [optional] serialized form of the headers Map<String, String>
ValueLength => int32
Value => bytes
|
...