181.2. オプション

設定 （共通）

エンドポイントが再利用する共通のオプションで Kafka コンポーネントを事前設定できます。

KafkaConfiguration

ブローカー （共通）

使用する Kafka ブローカーの URL。形式は host1:port1,host2:port2 であり、一覧はブローカーのサブセットを参照するブローカーまたは VIP のサブセットになります。このオプションは、Kafka ドキュメントの bootstrap.servers と呼ばれます。

文字列

workerPool (advanced)

共有カスタムワーカープールを使用して、Kafka サーバーが非同期非ブロッキング処理を使用して KafkaProducer から送信されたメッセージを確認した後もルーティングエクスチェンジを続行します。このオプションを使用する場合、必要なくなった場合にプールをシャットダウンするためにスレッドプールのライフサイクルを処理する必要があります。

ExecutorService

useGlobalSslContext Parameters (security)

グローバル SSL コンテキストパラメーターの使用を有効にします。

false

boolean

breakOnFirstError (consumer)

このオプションは、コンシューマーがエクスチェンジを処理し、失敗したときに発生する内容を制御します。オプションが false の場合、コンシューマーは次のメッセージを継続し、処理します。オプションが true の場合、コンシューマーは破損し、失敗の原因となったメッセージのオフセットにシークし、再度このメッセージを処理します。ただし、これにより、同じメッセージが毎回失敗すると、同じメッセージが無限に処理される可能性があります（例： poison メッセージ）。そのため、Camel のエラーハンドラーなどを使用してこれに対応することが推奨されます。

false

boolean

allowManualCommit (consumer)

KafkaManualCommit を使用して手動のコミットを許可するかどうか。このオプションを有効にすると、KafkaManualCommit のインスタンスは Exchange メッセージヘッダーに保存されます。これにより、エンドユーザーはこの API にアクセスし、Kafka コンシューマー経由で手動のオフセットコミットを実行できます。

false

boolean

kafkaManualCommit Factory (consumer)

KafkaManualCommit インスタンスの作成に使用するファクトリー。これにより、カスタムファクトリーをプラグインしてカスタム KafkaManualCommit インスタンスを作成できます。

KafkaManualCommit Factory

resolveProperty Placeholders (advanced)

起動時にコンポーネント自体がプロパティープレースホルダーを解決するかどうか。String タイプのプロパティーのみがプロパティープレースホルダーを使用できます。

true

boolean