0

複数のパーティションを持つ単一のトピックでカフカ プロデューサーを実装しています。メッセージ内の特定の値 (メッセージ json の feedName プロパティ値) によってメッセージが移動するパーティションを選択しています。feedName - partitionId マッピングの SQL テーブルを維持しています。私の質問は、パーティション ID はリーダーとレプリカで同じになりますか? 異なる場合、すべてのブローカーでパーティションを一意に識別するにはどうすればよいですか?

4

2 に答える 2

-1

パーティション ID は不変のメッセージ シーケンスです。Kafkaのドキュメントでも同じことがわかります

各パーティションは、コミット ログに継続的に追加される、順序付けられた不変のメッセージ シーケンスです。

あなたのユースケースでは、id と feedName のマッピングについて心配する必要はありません。

お役に立てれば！

于 2016-03-22T14:21:02.693 に答える