合流kafka休息avrò生產者

Question

我使用合流kafka休息產生avro消息，當我使用其餘端點消耗它時，返回格式是這樣的。

{ 
    "key":null, 
    "value": {ACTUAL_PAYLOAD}, 
    "partition":X,"offset":0 
} 

我想知道kafka的消息實際上是這種格式，或者消費者端點添加了「key」和「partition」。如果它是前一個，它會很奇怪，因爲在這種情況下，當您執行產品請求（與ACTUAL_PAYLOAD相匹配的模式）時，響應有效負載avro模式不一樣。

Answer 1

當您使用kafka一個客戶它要求一個Key和一個值，這個值就是你的有效載荷。偏移量和分區是kafka的內部值，每個記錄都有一個，它表示它在日誌中的位置。密鑰爲空，因爲沒有提供密鑰。