Key:消息键,对消息做partition时使用,即决定消息被保存到某个topic下的哪个partition。
Value:消息体,保存实际的消息数据。
Timestamp:消息发送时间戳,用于流式处理及其他依赖时间的处理语义。如果不指定,则取当前时间。
属性字段:kafka为该字段分配了1字节。目前使用了最低的3位用于保存消息的压缩类型,其余5位尚未使用。
当前支持4种压缩类型:0(无压缩)、1(GZIP)、2(Snappy)、3(LZ4)。
kafka承诺只要这个集合中至少存在一个replica,那些“已提交”状态的消息就不会丢失。
1、ISR中至少存在一个“活着的”replica。
2、“已提交”消息。