1

私はコンフルエントな kafka-rest を使用して avro メッセージを生成します。rest エンドポイントを使用してそれを消費すると、返される形式は次のようになります。

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

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

4

1 に答える 1

1

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

于 2016-10-15T00:02:51.437 に答える