Kafka消息格式

kafka消息
  • Key:消息键,对消息做partition时使用,即决定消息被保存到某个topic下的哪个partition。

  • Value:消息体,保存实际的消息数据。

  • Timestamp:消息发送时间戳,用于流式处理及其他依赖时间的处理语义。如果不指定,则取当前时间。

  • 属性字段:kafka为该字段分配了1字节。目前使用了最低的3位用于保存消息的压缩类型,其余5位尚未使用。

当前支持4种压缩类型:0(无压缩)、1(GZIP)、2(Snappy)、3(LZ4)。

kafka承诺只要这个集合中至少存在一个replica,那些“已提交”状态的消息就不会丢失。

1、ISR中至少存在一个“活着的”replica。

2、“已提交”消息。

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容