5.7. Elasticsearch
5.7.1. camel-elasticsearch-rest-kafka-connector シンク設定
コネクターの説明: REST API を介して ElasticSearch でリクエストを送信します。
camel-elasticsearch-rest-kafka-connector をシンクとして使用する場合は、次の Maven 依存関係を使用してコネクターをサポートしてください。
<dependency>
<groupId>org.apache.camel.kafkaconnector</groupId>
<artifactId>camel-elasticsearch-rest-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.elasticsearchrest.CamelElasticsearchrestSinkConnectorcamel-elasticsearch-rest シンクコネクターは、以下に示す 31 のオプションをサポートします。
| 名前 | 説明 | デフォルト | 必要性 | 優先順位 |
|---|---|---|---|---|
| camel.sink.path.clusterName | クラスターの名前。 | null | true | HIGH |
| camel.sink.endpoint.connectionTimeout | 接続がタイムアウトするまでのミリ秒単位の待機時間。 | 30000 | false | MEDIUM |
| camel.sink.endpoint.disconnect | プロデューサーの呼び出しが終了したら切断します | false | false | MEDIUM |
| camel.sink.endpoint.enableSniffer | 実行中の Elasticsearch クラスターからのノードの自動検出を有効にする | false | false | MEDIUM |
| camel.sink.endpoint.enableSSL | SSL の有効化 | false | false | MEDIUM |
| camel.sink.endpoint.from | 応答の開始インデックス。 | null | false | MEDIUM |
| camel.sink.endpoint.hostAddresses | 使用する ip:port 形式のリモートトランスポートアドレスを含むコンマ区切りのリスト。 | null | true | HIGH |
| camel.sink.endpoint.indexName | 動作させるインデックスの名前。 | null | false | MEDIUM |
| camel.sink.endpoint.lazyStartProducer | 最初のメッセージでプロデューサーをレイジーに起動すべきかどうか。レイジーに起動することで、起動時にプロデューサーが失敗し、それによりルートが失敗する可能性がある状況で、CamelContext およびルートの起動を許可します。レイジーな起動を延期すると、Camel のルーティングエラーハンドラー経由でメッセージのルーティング中に起動の失敗を処理できます。最初のメッセージが処理されるときに、プロデューサーの作成および起動に若干時間がかかり、合計処理時間が長くなる可能性があることに注意してください。 | false | false | MEDIUM |
| camel.sink.endpoint.maxRetryTimeout | 再試行までの時間 (ミリ秒) | 30000 | false | MEDIUM |
| camel.sink.endpoint.operation | 実行する操作: [Index] [Update] [Bulk] [BulkIndex] [GetById] [MultiGet] [MultiSearch] [Delete] [DeleteIndex] [Search] [Exists] [Ping] のいずれか | null | false | MEDIUM |
| camel.sink.endpoint.scrollKeepAliveMs | Elasticsearch が検索コンテキストを維持するミリ秒単位の時間 | 60000 | false | MEDIUM |
| camel.sink.endpoint.size | レスポンスのサイズ。 | null | false | MEDIUM |
| camel.sink.endpoint.sniffAfterFailureDelay | 失敗後にスケジュールされたスニファ実行の遅延 (ミリ秒単位) | 60000 | false | MEDIUM |
| camel.sink.endpoint.snifferInterval | 通常のスニファを連続して実行する間隔 (ミリ秒単位)。sniffOnFailure が無効になっている場合、または連続するスニファ実行の間に失敗がない場合に受け入れられます | 300000 | false | MEDIUM |
| camel.sink.endpoint.socketTimeout | ソケットがタイムアウトする前に待機するミリ秒単位のタイムアウト。 | 30000 | false | MEDIUM |
| camel.sink.endpoint.useScroll | スクロールの使用を有効にする | false | false | MEDIUM |
| camel.sink.endpoint.waitForActiveShards | インデックスの作成は、シャードの書き込み整合性数が使用可能になるまで待機します | 1 | false | MEDIUM |
| camel.component.elasticsearch-rest.lazyStart Producer | 最初のメッセージでプロデューサーをレイジーに起動すべきかどうか。レイジーに起動することで、起動時にプロデューサーが失敗し、それによりルートが失敗する可能性がある状況で、CamelContext およびルートの起動を許可します。レイジーな起動を延期すると、Camel のルーティングエラーハンドラー経由でメッセージのルーティング中に起動の失敗を処理できます。最初のメッセージが処理されるときに、プロデューサーの作成および起動に若干時間がかかり、合計処理時間が長くなる可能性があることに注意してください。 | false | false | MEDIUM |
| camel.component.elasticsearch-rest.autowired Enabled | 自動ワイヤリングが有効になっているかどうか。これは、コンポーネントで設定される一致するタイプのインスタンスが 1 つあるかどうかを検出するためにレジストリーを検索することで、自動ワイアリングオプションに使用されます (オプションは自動ワイアとマーク付けされる必要があります)。これは、JDBC データソース、JMS 接続ファクトリー、AWS クライアントなどの自動設定に使用できます。 | true | false | MEDIUM |
| camel.component.elasticsearch-rest.client | エンドポイントごとにクライアントを作成する代わりに、既存の設定済み Elasticsearch クライアントを使用するには。これにより、特定の設定でクライアントをカスタマイズできます。 | null | false | MEDIUM |
| camel.component.elasticsearch-rest.connection Timeout | 接続がタイムアウトするまでのミリ秒単位の待機時間。 | 30000 | false | MEDIUM |
| camel.component.elasticsearch-rest.enableSniffer | 実行中の Elasticsearch クラスターからのノードの自動検出を有効にする | "false" | false | MEDIUM |
| camel.component.elasticsearch-rest.hostAddresses | 使用する ip:port 形式のリモートトランスポートアドレスを含むコンマ区切りのリスト。代わりに hostAddresses が考慮されるようにするには、ip オプションと port オプションを空白のままにする必要があります。 | null | false | MEDIUM |
| camel.component.elasticsearch-rest.maxRetryTimeout | 再試行までの時間 (ミリ秒) | 30000 | false | MEDIUM |
| camel.component.elasticsearch-rest.sniffAfter FailureDelay | 失敗後にスケジュールされたスニファ実行の遅延 (ミリ秒単位) | 60000 | false | MEDIUM |
| camel.component.elasticsearch-rest.snifferInterval | 通常のスニファを連続して実行する間隔 (ミリ秒単位)。sniffOnFailure が無効になっている場合、または連続するスニファ実行の間に失敗がない場合に受け入れられます | 300000 | false | MEDIUM |
| camel.component.elasticsearch-rest.socketTimeout | ソケットがタイムアウトする前に待機するミリ秒単位のタイムアウト。 | 30000 | false | MEDIUM |
| camel.component.elasticsearch-rest.enableSSL | SSL の有効化 | "false" | false | MEDIUM |
| camel.component.elasticsearch-rest.password | 認証用パスワード | null | false | MEDIUM |
| camel.component.elasticsearch-rest.user | 基本認証ユーザー | null | false | MEDIUM |
camel-elasticsearch-rest シンクコネクターには、すぐに使えるコンバーターはありません。
camel-elasticsearch-rest シンクコネクターは、すぐに使用できる 0 変換をサポートします。これを以下に示します。
org.apache.camel.kafkaconnector.elasticsearchrest.transformers.ConnectRecordValueToMapTransformscamel-elasticsearch-rest シンクコネクターには、すぐに使用できる集約ストラテジーはありません。
'%20d='M201.5%20305.5c-13.8%200-24.9-11.1-24.9-24.6%200-13.8%2011.1-24.9%2024.9-24.9%2013.6%200%2024.6%2011.1%2024.6%2024.9%200%2013.6-11.1%2024.6-24.6%2024.6zM504%20256c0%20137-111%20248-248%20248S8%20393%208%20256%20119%208%20256%208s248%20111%20248%20248zm-132.3-41.2c-9.4%200-17.7%203.9-23.8%2010-22.4-15.5-52.6-25.5-86.1-26.6l17.4-78.3%2055.4%2012.5c0%2013.6%2011.1%2024.6%2024.6%2024.6%2013.8%200%2024.9-11.3%2024.9-24.9s-11.1-24.9-24.9-24.9c-9.7%200-18%205.8-22.1%2013.8l-61.2-13.6c-3-.8-6.1%201.4-6.9%204.4l-19.1%2086.4c-33.2%201.4-63.1%2011.3-85.5%2026.8-6.1-6.4-14.7-10.2-24.1-10.2-34.9%200-46.3%2046.9-14.4%2062.8-1.1%205-1.7%2010.2-1.7%2015.5%200%2052.6%2059.2%2095.2%20132%2095.2%2073.1%200%20132.3-42.6%20132.3-95.2%200-5.3-.6-10.8-1.9-15.8%2031.3-16%2019.8-62.5-14.9-62.5zM302.8%20331c-18.2%2018.2-76.1%2017.9-93.6%200-2.2-2.2-6.1-2.2-8.3%200-2.5%202.5-2.5%206.4%200%208.6%2022.8%2022.8%2087.3%2022.8%20110.2%200%202.5-2.2%202.5-6.1%200-8.6-2.2-2.2-6.1-2.2-8.3%200zm7.7-75c-13.6%200-24.6%2011.1-24.6%2024.9%200%2013.6%2011.1%2024.6%2024.6%2024.6%2013.8%200%2024.9-11.1%2024.9-24.6%200-13.8-11-24.9-24.9-24.9z'/%3e%3c/svg%3e){kind=small}