Key:消息鍵那婉,對消息做partition時使用卸亮,即決定消息被保存到某個topic下的哪個partition塑荒。
Value:消息體熄赡,保存實際的消息數(shù)據(jù)。
Timestamp:消息發(fā)送時間戳齿税,用于流式處理及其他依賴時間的處理語義彼硫。如果不指定,則取當(dāng)前時間偎窘。
屬性字段:kafka為該字段分配了1字節(jié)乌助。目前使用了最低的3位用于保存消息的壓縮類型,其余5位尚未使用陌知。
當(dāng)前支持4種壓縮類型:0(無壓縮)他托、1(GZIP)、2(Snappy)仆葡、3(LZ4)赏参。
kafka承諾只要這個集合中至少存在一個replica志笼,那些“已提交”狀態(tài)的消息就不會丟失。
1把篓、ISR中至少存在一個“活著的”replica纫溃。
2、“已提交”消息韧掩。