kafka消息格式

半兽人 发表于: 2015-03-10   最后更新时间: 2016-09-12  
  •   40 订阅,2402 游览

5.4 消息格式

/** 
	 * A message. The format of an N byte message is the following: 
	 * 
	 * If magic byte is 0 
	 * 
	 * 1. 1 byte "magic" identifier to allow format changes 
	 * 
	 * 2. 4 byte CRC32 of the payload 
	 * 
	 * 3. N - 5 byte payload 
	 * 
	 * If magic byte is 1 
	 * 
	 * 1. 1 byte "magic" identifier to allow format changes 
	 * 
	 * 2. 1 byte "attributes" identifier to allow annotations on the message independent of the version (e.g. compression enabled, type of codec used) 
	 * 
	 * 3. 4 byte CRC32 of the payload 
	 * 
	 * 4. N - 6 byte payload 
	 * 
	 */






发表于: 1年前   最后更新时间: 4月前   游览量:2402
上一条: kafka消息
下一条: kafka日志
评论…

  • 评论…
    • in this conversation
      提问