THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||
|---|---|---|
| ||
MessageAndOffset => Offset MessageSize Offset Message MessageSizeOffset => int32int64 OffsetMessageSize => int64int32 Message => Crc MagicByte Attributes Timestamp KeyLength Key ValueLength Value Crc => int32 MagicByte => int8 <---------------------- Bump up magic byte to 1 Attributes => int8 Timestamp => int64 <---------------------- NEW KeyLength => int32 Key => bytes ValueLength => int32 Value => bytes |
Note: Because this KIP will be implemented in the same patch of KIP-31. The magic byte 1 also means the relative offset is used.
Add a time field to both ProducerRecord and ConsumerRecord
...