原文地址：https://kafka.apache.org/0101/documentation.html#messages
消息包含一個(gè)固定大小的頭，一個(gè)變長(zhǎng)且“不透明”的byte數(shù)組表示的key和一個(gè)變長(zhǎng)且“不透明”的byte數(shù)組表示的內(nèi)容逻住。header包含以下內(nèi)容：
- A CRC32 checksum to detect corruption or truncation.
- A format version.
- An attributes identifier
- A timestamp
保持key和value的不透明是正確的決定：現(xiàn)在序列化方面取得了巨大的進(jìn)展蛮浑，選擇特定的一個(gè)序列化方式都不太適合所有的場(chǎng)景。不用說(shuō)使用Kafka的特定程序可能需要特定的序列化方式绢慢。MessageSet接口是批量讀寫(xiě)消息到NIO Channel的迭代器灿渴。
