Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagejava
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

...