コンフルエントカフカレストavròプロデューサー

Question

私はコンフルエントなカフカレストを使ってavroメッセージを生成します。残りのエンドポイントを使用してそれを消費すると、リターン形式は次のようになります。

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

私はカフカ内のメッセージは、実際に、この形式の「キー」と「パーティションは」消費者のエンドポイントによって追加されるのだろうか。これは、前者の場合は奇妙なものになります。この場合、プロダクションリクエスト（ACTUAL_PAYLOADと一致するスキーマ）を実行するとき、レスポンスペイロードavroスキーマは同じではないからです（ACTUAL_PAYLOADと一致するスキーマ）。

Answer 1

それ以降は、クライアントはキーと値を要求します。値はここのペイロードです。オフセットとパーティションはkafkaの内部値であり、各レコードには1つの値があり、その値はログ内の位置を表します。キーは提供されていないので、Keyはnullです。