4.4.5. パーティション

MongoDB コネクターは、イベントのトピックパーティションを明示的に決定しません。代わりに、Kafka がキーに基づいてパーティションを判別できるようにします。Kafka Connect ワーカー設定で Partitioner 実装の名前を定義して、Kafka のパーティショニングロジックを変更できます。

Kafka は、1 つのトピックパーティションに書き込まれたイベントにのみ順序の合計を維持します。キーによるイベントのパーティション設定により、同じキーを持つすべてのイベントは常に同じパーティションに送信されます。これにより、特定のドキュメントのすべてのイベントが常に正しく順序付けられます。