...
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 => VarInt Key => bytes HeadersCountHeadersLength => VarInt <--------------- NEW size of the byte[] of the serialised headers if headers Headers => bytes <--------------------- NEW serialised form of the Header[] ValueLength => VarInt Value => bytes |
...