一個Kafka的Message由一個固定長度的header和一個變長的消息體body組成
header部分由一個字節的magic(文件格式)和四個字節的CRC32(用於判斷body消息體是否正常)構成。
當magic的值為1的時候，會在magic和crc32之間多一個字節的數據：attributes(保存一些相關屬性，
比如是否壓縮、壓縮格式等等);如果magic的值為0，那么不存在attributes屬性
body是由N個字節構成的一個消息體，包含了具體的key/value消息
免責聲明！
本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。