5.13.2. camel-mongodb-kafka-connector ソース設定

camel.source.path.connectionBean

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

null

true

HIGH

camel.source.endpoint.collection

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

null

false

MEDIUM

camel.source.endpoint.collectionIndex

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

null

false

MEDIUM

camel.source.endpoint.createCollection

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

true

false

MEDIUM

camel.source.endpoint.database

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

null

false

MEDIUM

camel.source.endpoint.mongoConnection

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

null

false

MEDIUM

camel.source.endpoint.operation

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

null

false

MEDIUM

camel.source.endpoint.outputType

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

null

false

MEDIUM

camel.source.endpoint.bridgeErrorHandler

コンシューマーの Camel ルーティングエラーハンドラーへのブリッジを許可します。よって、コンシューマーが受信メッセージなどの取得を試行している間に発生した例外は、メッセージとして処理され、ルーティングエラーハンドラーによって処理されます。デフォルトでは、コンシューマーは org.apache.camel.spi.ExceptionHandler を使用して例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。

false

false

MEDIUM

camel.source.endpoint.consumerType

コンシューマータイプ。

null

false

MEDIUM

camel.source.endpoint.exceptionHandler

コンシューマーによるカスタム ExceptionHandler の使用を許可します。bridgeErrorHandler オプションが有効な場合は、このオプションは使用されないことに注意してください。デフォルトでは、コンシューマーは例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。

null

false

MEDIUM

camel.source.endpoint.exchangePattern

コンシューマーがエクスチェンジを作成する際に交換パターンを設定します。[InOnly]、[InOut]、[InOptionalOut] のいずれか。

null

false

MEDIUM

camel.source.endpoint.cursorRegenerationDelay

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

1000L

false

MEDIUM

camel.source.endpoint.dynamicity

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

false

false

MEDIUM

camel.source.endpoint.readPreference

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

PRIMARY

false

MEDIUM

camel.source.endpoint.writeConcern

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

ACKNOWLEDGED

false

MEDIUM

camel.source.endpoint.writeResultAsHeader

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

false

false

MEDIUM

camel.source.endpoint.streamFilter

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

null

false

MEDIUM

camel.source.endpoint.persistentId

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

null

false

MEDIUM

camel.source.endpoint.persistentTailTracking

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

false

false

MEDIUM

camel.source.endpoint.tailTrackCollection

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

null

false

MEDIUM

camel.source.endpoint.tailTrackDb

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

null

false

MEDIUM

camel.source.endpoint.tailTrackField

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

null

false

MEDIUM

camel.source.endpoint.tailTrackIncreasingField

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

null

false

MEDIUM

camel.component.mongodb.mongoConnection

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

null

false

MEDIUM

camel.component.mongodb.bridgeErrorHandler

コンシューマーの Camel ルーティングエラーハンドラーへのブリッジを許可します。よって、コンシューマーが受信メッセージなどの取得を試行している間に発生した例外は、メッセージとして処理され、ルーティングエラーハンドラーによって処理されます。デフォルトでは、コンシューマーは org.apache.camel.spi.ExceptionHandler を使用して例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。

false

false

MEDIUM

camel.component.mongodb.autowiredEnabled

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

true

false

MEDIUM