mirror of https://github.com/apache/kafka.git
KAFKA-9255: Add 'timestamp' field to 'message' entry (#7764)
Reviewers: Mickael Maison <mickael.maison@gmail.com>
This commit is contained in:
parent
0b8ea7e162
commit
a2aa0a458b
|
@ -130,7 +130,7 @@
|
||||||
MessageSet (Version: 1) => [offset message_size message]
|
MessageSet (Version: 1) => [offset message_size message]
|
||||||
offset => INT64
|
offset => INT64
|
||||||
message_size => INT32
|
message_size => INT32
|
||||||
message => crc magic_byte attributes key value
|
message => crc magic_byte attributes timestamp key value
|
||||||
crc => INT32
|
crc => INT32
|
||||||
magic_byte => INT8
|
magic_byte => INT8
|
||||||
attributes => INT8
|
attributes => INT8
|
||||||
|
@ -143,7 +143,7 @@
|
||||||
0: create time
|
0: create time
|
||||||
1: log append time
|
1: log append time
|
||||||
bit 4~7: unused
|
bit 4~7: unused
|
||||||
timestamp =>INT64
|
timestamp => INT64
|
||||||
key => BYTES
|
key => BYTES
|
||||||
value => BYTES
|
value => BYTES
|
||||||
</pre></p>
|
</pre></p>
|
||||||
|
|
Loading…
Reference in New Issue