kafka消息格式
2019-10-24 10:01:17 0 举报
kafka消息格式
作者其他创作
大纲/内容
base offset
0
15
Record
4
CRC32
压缩类型
8B
attributes
offset delta
2B
header key length
value length
header value length
4B
varint
magic
timestamp
3
时间戳类型
1B
Header
key
事物
10
12
offset
key length
6
5
header value
控制批次
保留
message size
max timestamp
1:N
value
Record Batch
9
kafka消息格式V0
7
last offset delta
13
1
length
first timestamp
2
header key
kafka消息格式V1
base sequence
timestamp delta
producer id
headers count
records count
11
batch length
partition leader epoch
8
kafka消息格式V2
records
headers
14
producer epoch
0:N
0 条评论
回复 删除
下一页
