Kafka內核總結

Kafka內核總結 1 Message 一個kafka的Message由一個固定長度的header和一個變長的消息體body組成。 header部分由一個字節的magic(文件格式)和四個字節的CRC32(用於判斷body消息體是否正常)構成。當magic的值爲1時，會在magic和CRC32之間多一個字節的數據:attributes(保存一些相關屬性，比如是否壓縮、壓縮格式等信息)；如果magi

>>阅读原文<<