5.13. MongoDB


5.13.1. camel-mongodb-kafka-connector sink configuration

コネクターの説明: MongoDB ドキュメントおよびコレクションに対して操作を実行します。

camel-mongodb-kafka-connector をシンクとして使用する場合、以下の Maven 依存関係を使用してコネクターをサポートするようにしてください。

<dependency>
  <groupId>org.apache.camel.kafkaconnector</groupId>
  <artifactId>camel-mongodb-kafka-connector</artifactId>
  <version>x.x.x</version>
  <!-- use the same version as your Camel Kafka connector version -->
</dependency>

Kafka コネクションでこのシンクコネクターを使用するには、以下の connector.class を設定する必要があります。

connector.class=org.apache.camel.kafkaconnector.mongodb.CamelMongodbSinkConnector

camel-mongodb シンクコネクターは、以下に示す 24 のオプションをサポートします。

Expand
名前説明デフォルト必要性優先順位

camel.sink.path.connectionBean

データベースに接続するためにクライアントをルックアップするために使用される接続 Bean 参照を設定します。

null

true

HIGH

camel.sink.endpoint.collection

このエンドポイントにバインドする MongoDB コレクションの名前を設定します

null

false

MEDIUM

camel.sink.endpoint.collectionIndex

コレクションのインデックスを設定します (JSON FORMAT : { field1 : order1、field2 : order2})

null

false

MEDIUM

camel.sink.endpoint.createCollection

コレクションが存在しない場合は、初期化中にコレクションを作成します。デフォルトは true です。

true

false

MEDIUM

camel.sink.endpoint.database

ターゲットに設定する MongoDB データベースの名前を設定します

null

false

MEDIUM

camel.sink.endpoint.mongoConnection

データベースに接続するためのクライアントとして使用される接続 Bean を設定します。

null

false

MEDIUM

camel.sink.endpoint.operation

このエンドポイントが MongoDB に対して実行する操作を設定します。[findById] [findOneByQuery] [findAll] [findDistinct] [insert] [save] [update] [remove] [bulkWrite] [aggregate] [getDbStats] [getColStats] [count] [command] のいずれか

null

false

MEDIUM

camel.sink.endpoint.outputType

プロデューサの出力を選択したタイプ (DocumentList Document または MongoIterable) に変換します。DocumentList または MongoIterable は、findAll および aggregate に適用されます。ドキュメントは、他のすべての操作に適用されます。One of: [DocumentList] [Document] [MongoIterable]

null

false

MEDIUM

camel.sink.endpoint.lazyStartProducer

最初のメッセージでプロデューサーをレイジーに起動すべきかどうか。レイジーに起動することで、起動時にプロデューサーが失敗し、それによりルートが失敗する可能性がある状況で、CamelContext およびルートの起動を許可します。レイジーな起動を延期すると、Camel のルーティングエラーハンドラー経由でメッセージのルーティング中に起動の失敗を処理できます。最初のメッセージが処理されるときに、プロデューサーの作成および起動に若干時間がかかり、合計処理時間が長くなる可能性があることに注意してください。

false

false

MEDIUM

camel.sink.endpoint.cursorRegenerationDelay

MongoDB の Tailable カーソルは、新しいデータが到着するまでブロックされます。新しいデータが挿入されない場合、しばらくするとカーソルが自動的に解放され、MongoDB サーバーによって閉じられます。クライアントは、必要に応じてカーソルを再生成する必要があります。この値は、新しいカーソルのフェッチを試行するまでの待機時間と、試行が失敗した場合に次の試行が行われるまでの時間を指定します。デフォルト値は 1000ms です。

1000L

false

MEDIUM

camel.sink.endpoint.dynamicity

このエンドポイントが受信 Exchange プロパティーからターゲットデータベースとコレクションを動的に解決しようとするかどうかを設定します。それ以外の場合は静的なエンドポイント URI で指定されたデータベースとコレクションを実行時にオーバーライドするために使用できます。パフォーマンスを向上させるために、デフォルトでは無効になっています。有効にすると、パフォーマンスへの影響は最小限に抑えられます。

false

false

MEDIUM

camel.sink.endpoint.readPreference

MongoDB クライアントが読み取り操作をレプリカセットのメンバーにルーティングする方法を設定します。使用可能な値は、PRIMARY、PRIMARY_PREFERRED、SECONDARY、SECONDARY_PREFERRED または NEAREST 次のいずれか [PRIMARY] [PRIMARY_PREFERRED] [SECONDARY] [SECONDARY_PREFERRED] [NEAREST]

PRIMARY

false

MEDIUM

camel.sink.endpoint.writeConcern

スタンドアロンの mongod、レプリカセット、またはクラスターへの書き込み操作のために MongoDB から要求された確認応答のレベルで接続 Bean を設定します。可能な値は、ACKNOWLEDGED、W1、W2、W3、UNACKNOWLEDGED、JOURNALED、または MAJORITY です。次のいずれか: [ACKNOWLEDGED] [W1] [W2] [W3] [UNACKNOWLEDGED] [JOURNALED] [MAJORITY]

ACKNOWLEDGED

false

MEDIUM

camel.sink.endpoint.writeResultAsHeader

書き込み操作では、OUT メッセージのボディとして WriteResult を返す代わりに、IN メッセージを OUT に転送し、WriteResult をヘッダーとして添付するかどうかを決定します。

false

false

MEDIUM

camel.sink.endpoint.streamFilter

変更ストリームコンシューマーのフィルター条件。

null

false

MEDIUM

camel.sink.endpoint.persistentId

1 つのテールトラッキングコレクションで、複数のテーラブルコンシューマー用に多数のトラッカーをホストできます。それらを分離しておくために、各トラッカーには独自の固有の persistentId が必要です。

null

false

MEDIUM

camel.sink.endpoint.persistentTailTracking

永続的な tail トラッキングを有効にします。これは、システムの再起動時に最後に消費されたメッセージを追跡するメカニズムです。次にシステムが起動すると、エンドポイントは最後にレコードを一気に読み込むのを停止した地点からカーソルを回復します。

false

false

MEDIUM

camel.sink.endpoint.tailTrackCollection

テールトラッキング情報が保持されるコレクション。指定しない場合、MongoDbTailTrackingConfig#DEFAULT_COLLECTION がデフォルトで使用されます。

null

false

MEDIUM

camel.sink.endpoint.tailTrackDb

テールトラッキングメカニズムが保持されるデータベースを示します。指定しない場合、現在のデータベースがデフォルトで選択されます。動的性は有効になっていても考慮されません。つまり、テールトラッキングデータベースは、エンドポイントの初期化を過ぎても変化しません。

null

false

MEDIUM

camel.sink.endpoint.tailTrackField

最後に追跡された値が配置されるフィールド。指定しない場合、MongoDbTailTrackingConfig#DEFAULT_FIELD がデフォルトで使用されます。

null

false

MEDIUM

camel.sink.endpoint.tailTrackIncreasingField

増加する性質の着信レコードの相関フィールドであり、生成されるたびに tail カーソルを配置するために使用されます。カーソルは次のタイプの tailTrackIncreasingField で (再) 作成されます:整数、日付、文字列などの型にすることができます。注: 現時点ではドット表記がサポートされていないため、フィールドはドキュメントの最上位にある必要があります。

null

false

MEDIUM

camel.component.mongodb.mongoConnection

接続に使用される共有クライアント。コンポーネントから生成されたすべてのエンドポイントは、この接続クライアントを共有します。

null

false

MEDIUM

camel.component.mongodb.lazyStartProducer

最初のメッセージでプロデューサーをレイジーに起動すべきかどうか。レイジーに起動することで、起動時にプロデューサーが失敗し、それによりルートが失敗する可能性がある状況で、CamelContext およびルートの起動を許可します。レイジーな起動を延期すると、Camel のルーティングエラーハンドラー経由でメッセージのルーティング中に起動の失敗を処理できます。最初のメッセージが処理されるときに、プロデューサーの作成および起動に若干時間がかかり、合計処理時間が長くなる可能性があることに注意してください。

false

false

MEDIUM

camel.component.mongodb.autowiredEnabled

自動ワイヤリングが有効になっているかどうか。これは、コンポーネントで設定される一致するタイプのインスタンスが 1 つあるかどうかを検出するためにレジストリーを検索することで、自動ワイアリングオプションに使用されます (オプションは自動ワイアとマーク付けされる必要があります)。これは、JDBC データソース、JMS 接続ファクトリー、AWS クライアントなどの自動設定に使用できます。

true

false

MEDIUM

camel-mongodb シンクコネクターには、すぐに使えるコンバーターはありません。

camel-mongodb シンクコネクターには、すぐに使える変換はありません。

camel-mongodb シンクコネクターには、すぐに使用できる集約ストラテジーはありません。

Red Hat logoGithubredditYoutubeTwitter

詳細情報

試用、購入および販売

コミュニティー

会社概要

Red Hat は、企業がコアとなるデータセンターからネットワークエッジに至るまで、各種プラットフォームや環境全体で作業を簡素化できるように、強化されたソリューションを提供しています。

多様性を受け入れるオープンソースの強化

Red Hat では、コード、ドキュメント、Web プロパティーにおける配慮に欠ける用語の置き換えに取り組んでいます。このような変更は、段階的に実施される予定です。詳細情報: Red Hat ブログ.

Red Hat ドキュメントについて

Legal Notice

Theme

© 2026 Red Hat
トップに戻る