--- schema_version: "1" id: f1c38e9374c9f59aec443d2ed896be07a101d584315918b8b9a9fae282350d63 title: Apache Kafka Connector 4.6 リファレンス collection: mulesoft version: current locale: ja-jp portal_url: https://docs.salesforce.com/mulesoft/current/ja-jp/kafka-connector/4.6/kafka-connector-reference.md canonical_url: https://docs.mulesoft.com/jp/kafka-connector/4.6/kafka-connector-reference source_site: docs.mulesoft.com content_type: documentation content_hash: fa811cdeb9bf6e7f71515860d1e8e3402789211abe882254dcd8173f2870e766 description: MuleSoft Documentation Site release: "4.6" latest: false --- # Apache Kafka Connector 4.6 リファレンス Apache Kafka 用 Anypoint Connector (Apache Kafka Connector) を使用すると、Apache Kafka メッセージングシステムとやりとりでき、Mule Runtime Engine (Mule) を使用した Mule アプリケーションと Apache Kafka クラスター間のシームレスなインテグレーションを実現できます。
Message Listener​ または ​Batch Message Listener​ で ​MANUAL​ 肯定応答モードを使用する場合、フローの最後で (エラーがなかったため、またはフローに ​On Error Continue​ コンポーネントがあるために) フローが正常に完了した時点で ​Commit​ 操作を使用する必要があります。
## [](#制限事項)制限事項 - コネクタで使用する Kafka ライブラリではネットワークの中断が内部で管理されるため、Mule サーバーの通知はサポートされません。 - Apache Kafka Connector では分散トレースはサポートされていません。 ## [](#consumer-config)Consumer Configuration (コンシューマー設定) Apache Kafka Connector のコンシューマーの設定。
名前 型 説明 デフォルト値 必須

Name (名前)

String (文字列)

この設定の名前。コネクタはこの名前の設定を参照します。

x

Connection (接続)

この設定の接続種別。

x

Default acknowledgement mode (デフォルトの肯定応答モード)

Enumeration (列挙)。次のいずれかになります。

  • AUTO

  • MANUAL

  • IMMEDIATE

  • DUPS_OK

Kafka ブローカーインスタンスにメッセージのコンシュームを通知する方法を定義します。

  • AUTO

    フローが正常に完了した場合にメッセージを自動的にコミットします。

  • MANUAL

    ユーザーは ​Commit​ 操作を使用して受信時にメッセージを手動でコミットする必要があります。

  • IMMEDIATE

    Mule は受信時にメッセージを自動的にコミットしてからフローをトリガーします。

  • DUPS_OK​

    [MANUAL] と同様に動作しますが、コミットが非同期のため、レコードが重複する可能性があります。

AUTO

Default listener poll timeout (デフォルトのリスナーポーリングタイムアウト)

Number (数値)

バッファでデータを使用 (フェッチ) できない場合にポーリングの実行を待機する時間。値が設定されていない場合は現在バッファで使用できるレコードと共にポーリングがすぐに返されされ、データがない場合は空が返されます。負数以外の値である必要があります。

100

Default listener poll timeout time unit (デフォルトのリスナーポーリングタイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Default listener poll timeout (デフォルトのリスナーポーリングタイムアウト)]​ 項目の時間単位。これを ​[Poll Timeout (ポーリングタイムアウト)]​ と組み合わせて、ポーリングの合計タイムアウトを定義します。

MILLISECONDS

Default operation poll timeout (デフォルトの操作ポーリングタイムアウト)

Number (数値)

操作が完了するのを待機する時間。値が設定されていない場合や負の値の場合、操作は永続的に待機します。

-1

Default operation poll timeout time unit (デフォルトの操作ポーリングタイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Default operation timeout (デフォルトの操作タイムアウト)]​ 項目の時間単位。これを ​[Operation Timeout (操作タイムアウト)]​ と組み合わせて、この設定を使用する操作のデフォルトの合計タイムアウトを定義します。

SECONDS

Zone ID (ゾーン ID)

String (文字列)

結果で指定のタイムスタンプを ​ZonedLocalDateTimes​ に変換します。デフォルト値は、システムによって提供されます。

Expiration Policy (有効期限ポリシー)

Expiration Policy (有効期限ポリシー)

動的設定インスタンスがアイドル状態を続けられる最小時間を設定します。この時間が経過すると、Mule Runtime で期限切れに相当するとみなされます。
### [](#consumer-plaintext)Consumer Plaintext (コンシューマープレーンテキスト) 接続種別 未認証の暗号化されていない接続種別を使用します。
名前 型 説明 デフォルト値 必須

Bootstrap Server URLs (ブートストラップサーバー URL)

Array of String (文字列の配列)

Kafka クラスターとの接続をブートストラップするサーバーのリスト。これは、使用可能なサーバーの部分的なリストになる場合があります。

x

Group ID (グループ ID)

String (文字列)

この設定を使用するすべての Kafka コンシューマーのデフォルトのグループ ID。

Consumer Amount (コンシューマー数)

Number (数値)

接続で最初に作成されるコンシューマーの数を決定します。

1

Maximum polling interval (最大ポーリング間隔)

Number (数値)

コンシューマーグループ管理を使用するときの poll() の呼び出し間の最大遅延。これにより、コンシューマーが他のレコードをフェッチするまでの許容アイドル時間の上限が設定されます。このタイムアウトの有効期限までに poll() がコールされないと、コンシューマーは失敗したとみなされ、パーティションを別のメンバーに再割り当てするためにグループが再調整されます。null でない ​group.instance.id​ を使用しているコンシューマーがこのタイムアウトに達しても、パーティションはすぐに再割り当てされません。代わりに、コンシューマーはハートビートの送信を停止します。​session.timeout.ms​ の有効期限が切れると、パーティションが再割り当てされます。

300

Maximum Polling Interval Time Unit (最大ポーリング間隔時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Maximum polling interval (最大ポーリング間隔)]​ 項目の時間単位。このパラメーターはソースレベルで上書きできます。

SECONDS

Isolation Level (分離レベル)

Enumeration (列挙)。次のいずれかになります。

  • READ_UNCOMMITTED​

  • READ_COMMITTED

トランザクションとして書き込まれるメッセージの読み取り方法を制御します。

  • READ_COMMITTED​

    consumer.poll()​ では、コミットされたトランザクションメッセージのみが返されます。

  • READ_UNCOMMITTED​

    consumer.poll()​ では、中止されたトランザクションメッセージも含め、すべてのメッセージが返されます。

非トランザクションメッセージは、どちらのモードでも無条件に返されます。メッセージは常にオフセット順に返されます。そのため、​READ_COMMITTED​ モードの場合、​consumer.poll()​ で、開かれている最初のトランザクションよりも 1 つ少ない最終安定オフセット (LSO) までのメッセージのみが返されます。

具体的には、実行中のトランザクションに属するメッセージの後に表示されるメッセージは、関連するトランザクションが完了するまで表示されません。その結果、​READ_COMMITTED​ コンシューマーは、インフライトトランザクションがあるときにハイウォーターマークまで読み取ることができません。さらに、​READ_COMMITTED​ では、​seekToEnd​ メソッドで LSO が返されます。

READ_UNCOMMITTED

Exclude internal topics (内部トピックを除外)

Boolean (ブール)

サブスクライブパターンに一致する内部トピックをサブスクリプションから除外するかどうかを決定します。常に明示的に内部トピックをサブスクライブできます。

true

Auto offset reset (自動オフセットリセット)

Enumeration (列挙)。次のいずれかになります。

  • EARLIEST

  • LATEST

  • ERROR

Kafka に初期オフセットがない場合や、(データの削除などで) 現在のオフセットがサーバーに存在しない場合の処理を決定します。

  • EARLIEST

    自動的に最も早いオフセットにリセットします。

  • LATEST

    自動的に最も遅いオフセットにリセットします。

  • ERROR

    コンシューマーのグループの前のオフセットが見つからない場合、エラーをスローします。

LATEST

Retry Backoff Timeout (再試行バックオフタイムアウト)

Number (数値)

特定のトピックパーティションに対して失敗した要求を再試行するまでの待機時間。これにより、一部の失敗シナリオの緊密なループで繰り返し要求が送信されることを回避できます。

100

Retry Backoff Timeout Time Unit (再試行バックオフタイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Retry Backoff Timeout (再試行バックオフタイムアウト)]​ 項目の時間単位。

MILLISECONDS

Check CRC (CRC をチェック)

Boolean (ブール)

コンシュームされるレコードの CRC32 を自動的にチェックします。これにより、ワイヤーまたはディスク上でメッセージに対するコンシュームが発生しなくなります。このチェックにより、オーバーヘッドが増えるため、非常に高いパフォーマンスが求められる状況では、これを無効にできます。

true

Default receive buffer size (デフォルトの受信バッファサイズ)

Number (数値)

データを読み込むときに使用する TCP 受信バッファのサイズ (​SO_RCVBUF​)。値が ​-1​ の場合、OS のデフォルトが使用されます。このパラメーターはソースレベルで上書きできます。

64

Default receive buffer size unit (デフォルトの受信バッファサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default receive buffer size (デフォルトの受信バッファサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

KB

Default send buffer size (デフォルトの送信バッファサイズ)

Number (数値)

データを送信するときに使用する TCP 送信バッファ (​SO_SNDBUF​) のサイズ。値が ​-1​ の場合、OS のデフォルトが使用されます。このパラメーターはソースレベルで上書きできます。

128

Default send buffer size unit (デフォルトの送信バッファサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default send buffer size (デフォルトの送信バッファサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

KB

Request Timeout (要求タイムアウト)

Number (数値)

クライアントが要求の応答を待機する最大時間。タイムアウトが経過する前に応答を受信できない場合、クライアントは必要に応じて要求を再送信します。再試行回数に達すると要求は失敗します。このパラメーターはソースレベルで上書きできます。

30

Request Timeout Time Unit (要求タイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Request Timeout (要求タイムアウト)]​ 項目の時間単位。このパラメーターはソースレベルで上書きできます。

SECONDS

Default record limit (デフォルトのレコード制限)

Number (数値)

Kafka クラスターへのポーリングコールで返されるレコードの最大数。このパラメーターはソースレベルで上書きできます。

500

DNS Lookups (DNS ルックアップ)

Enumeration (列挙)。次のいずれかになります。

  • DEFAULT

  • USE_ALL_DNS_IPS​

  • RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY

クライアントによる DNS ルックアップの使用方法を制御します。

  • USE_ALL_DNS_IPS​

    ルックアップでホスト名の複数の IP アドレスが返されると、接続に失敗するまですべての IP アドレスへの接続が試行されます。ブートストラップサーバーとアドバタイズサーバーの両方に適用されます。

  • RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY​

    各エントリが解決されて、正規名のリストに展開されます。

USE_ALL_DNS_IPS

Heartbeat interval (ハートビート間隔)

Number (数値)

Kafka のグループ管理機能を使用しているときのコンシューマーコーディネーターへのハートビート間の想定間隔。ハートビートは、コンシューマーのセッションがアクティブなままになっていることを確認したり、新しいコンシューマーがグループに参加したときやグループから脱退したときに再調整を容易にするために使用されます。値は ​session.timeout.ms​ 未満に設定する必要がありますが、通常はその値の 1/3 以下に設定することをお勧めします。通常の再調整の場合、さらに低い値に調整して、想定時間を制御できます。

3

Heartbeat Interval Time Unit (ハートビート間隔時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Heartbeat interval (ハートビート間隔)]​ 項目の時間単位。

SECONDS

Session Timeout (セッションタイムアウト)

Number (数値)

Kafka のグループ管理機能を使用しているときにコンシューマーの失敗を検出するために使用されるタイムアウト。コンシューマーは定期的にハートビートを送信し、生存していることをブローカーに示します。このセッションタイムアウトの期限までにハートビートを受信できない場合、ブローカーはこのコンシューマーをグループから削除し、再調整を開始します。この値は、ブローカー設定の ​group.min.session.timeout.ms​ と ​group.max.session.timeout.ms​ で設定される許容範囲に収まっている必要があります。

10

Session timeout time unit (セッションタイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Session Timeout (セッションタイムアウト)]​ 項目の時間単位。

SECONDS

Connection maximum idle time (最大接続アイドル時間)

Number (数値)

この設定で指定されたミリ秒が経過すると、アイドル接続が終了します。

540

Connection maximum idle time time unit (最大接続アイドル時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Connection maximum idle time (接続の最大アイドル時間)]​ 項目の時間単位。

SECONDS

TLS Configuration (TLS 設定)

TLS

Mule アプリケーションの通信を保護するためにクライアント側とサーバー側の両方で使用される TLS 設定を定義します。コネクタは、通信で使用する ​security.protocol​ を自動的に設定します。有効な値は ​PLAINTEXT​、​SSL​、​SASL_PLAINTEXT​、​SASL_SSL​ です。デフォルト値は ​PLAINTEXT​ または ​SASL_PLAINTEXT​ (SASL 認証 (kerberos/scram/plain) の場合) です。ブローカーで ​SSL​ がプロトコルとして設定されている場合、設定の ​tls:context​ 子要素で少なくともキーストアを設定します。また、コネクタは ​security.protocol​ として ​SSL​ (SASL 認証の場合は ​SASL_SSL​) を自動的に使用します。

Endpoint identification algorithm (エンドポイント識別アルゴリズム)

String (文字列)

クライアントがサーバーのホスト名を検証するために使用するエンドポイント識別アルゴリズム。デフォルト値は空の文字列です。つまり、エンドポイント識別アルゴリズムは無効になっています。クライアント (ブローカーによって作成されたブローカー間の通信のクライアント接続を含む) は、ブローカーのホスト名がブローカーの証明書のホスト名と一致していることを確認します。

Topic Subscription Patterns (トピックサブスクリプションパターン)

Array of String (文字列の配列)

サブスクライブするサブスクリプションの正規表現のリスト。トピックは、トピックコンシューマー間で自動的に再調整されます。

Assignments (割り当て)

Topic Partition (トピックパーティション)​ の配列

割り当てるトピック-パーティションペアのリスト。コンシューマーは自動的に再調整されません。

Default fetch minimum size (デフォルトの最小フェッチサイズ)

Number (数値)

フェッチ要求に対してサーバーが返すデータの最小量。十分なデータを使用できない場合、要求は指定された最小データ量が蓄積されて要求の応答が行われるまで待機します。デフォルトでは ​1​ バイトに設定されています。これは、データの到着を待機したままフェッチ要求がタイムアウトする場合を除き、1 バイトのデータが使用できるようになるとすぐにフェッチ要求の応答が返されることを意味します。これを ​1​ より大きな値に設定すると、サーバーはより大きなデータ量が蓄積されるまで待機します。これにより、レイテンシーは増えますが、サーバーのスループットは若干向上します。このパラメーターはソースレベルで上書きできます。

1

Fetch Minimum Size Unit (最小フェッチサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default fetch minimum size (デフォルトの最小フェッチサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

BYTE

Default fetch maximum size (デフォルトの最大フェッチサイズ)

Number (数値)

フェッチ要求に対してサーバーが返すデータの最大量。コンシューマーは、まとめてレコードをフェッチします。フェッチの最初の空でないパーティションの最初のレコードバッチがこの値より大きい場合でも、コンシューマーが処理を続行できるようにレコードバッチが返されます。そのため、これは絶対最大値ではありません。ブローカーで受け入れられる最大レコードバッチサイズは、​message.max.bytes​ (ブローカー設定) または ​max.message.bytes​ (トピック設定) を使用して定義されます。コンシューマーは複数のフェッチを並列で実行します。このパラメーターはソースレベルで上書きできます。

1

Default maximum fetch size unit (デフォルトの最大フェッチサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default fetch maximum size (デフォルトの最大フェッチサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

MB

Default maximum partition fetch size (デフォルトの最大パーティションフェッチサイズ)

Number (数値)

サーバーが返すパーティションあたりの最大データ量。コンシューマーは、まとめてレコードをフェッチします。フェッチの最初の空でないパーティションの最初のレコードバッチがこの制限より大きい場合でも、コンシューマーが処理を続行できるようにバッチが返されます。ブローカーで受け入れられる最大レコードバッチサイズは、​message.max.bytes​ (ブローカー設定) または ​max.message.bytes​ (トピック設定) を使用して定義されます。コンシューマーの要求サイズの制限については、​fetch.max.bytes​ を参照してください。このパラメーターはソースレベルで上書きできます。

1

Default maximum partition fetch unit (デフォルトの最大パーティションフェッチ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default maximum partition fetch size (デフォルトの最大パーティションフェッチサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

MB

Fetch Maximum Wait Timeout (最大フェッチ待機タイムアウト)

Number (数値)

fetch.min.bytes​ で指定された要件をすぐに満たすだけの十分なデータがない場合のフェッチ要求に応答するまでの最大サーバーブロック時間。

500

Fetch Maximum Wait Timeout Unit (最大フェッチ待機タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Fetch Maximum Wait Timeout (最大フェッチ待機タイムアウト)]​ 項目の時間単位。

MILLISECONDS

Reconnection (再接続)

Reconnection (再接続)

コネクタ操作で外部サーバーへの接続に失敗した場合に使用する再接続戦略を設定します。
### [](#consumer-sasl-kerberos)Consumer Kerberos (コンシューマー Kerberos) 接続種別 Kerberos 設定ファイルを使用します。
名前 型 説明 デフォルト値 必須

Bootstrap Server URLs (ブートストラップサーバー URL)

Array of String (文字列の配列)

Kafka クラスターとの接続をブートストラップするサーバーのリスト。これは、使用可能なサーバーの部分的なリストになる場合があります。

x

Group ID (グループ ID)

String (文字列)

この設定を使用するすべての Kafka コンシューマーのデフォルトのグループ ID。

Consumer Amount (コンシューマー数)

Number (数値)

接続で最初に作成されるコンシューマーの数を決定します。

1

Maximum polling interval (最大ポーリング間隔)

Number (数値)

コンシューマーグループ管理を使用するときの poll() の呼び出し間の最大遅延。これにより、コンシューマーが他のレコードをフェッチするまでの許容アイドル時間の上限が設定されます。このタイムアウトの有効期限までに poll() がコールされないと、コンシューマーは失敗したとみなされ、パーティションを別のメンバーに再割り当てするためにグループが再調整されます。null でない ​group.instance.id​ を使用しているコンシューマーがこのタイムアウトに達しても、パーティションはすぐに再割り当てされません。代わりに、コンシューマーはハートビートの送信を停止します。​session.timeout.ms​ の有効期限が切れると、パーティションが再割り当てされます。

300

Maximum Polling Interval Time Unit (最大ポーリング間隔時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Maximum polling interval (最大ポーリング間隔)]​ 項目の時間単位。このパラメーターはソースレベルで上書きできます。

SECONDS

Isolation Level (分離レベル)

Enumeration (列挙)。次のいずれかになります。

  • READ_UNCOMMITTED​

  • READ_COMMITTED

トランザクションとして書き込まれるメッセージの読み取り方法を制御します。

  • READ_COMMITTED​

    consumer.poll()​ では、コミットされたトランザクションメッセージのみが返されます。

  • READ_UNCOMMITTED​

    consumer.poll()​ では、中止されたトランザクションメッセージも含め、すべてのメッセージが返されます。

非トランザクションメッセージは、どちらのモードでも無条件に返されます。メッセージは常にオフセット順に返されます。そのため、​READ_COMMITTED​ モードの場合、​consumer.poll()​ で、開かれている最初のトランザクションよりも 1 つ少ない最終安定オフセット (LSO) までのメッセージのみが返されます。

具体的には、実行中のトランザクションに属するメッセージの後に表示されるメッセージは、関連するトランザクションが完了するまで表示されません。その結果、​READ_COMMITTED​ コンシューマーは、インフライトトランザクションがあるときにハイウォーターマークまで読み取ることができません。さらに、​READ_COMMITTED​ では、​seekToEnd​ メソッドで LSO が返されます。

READ_UNCOMMITTED

Exclude internal topics (内部トピックを除外)

Boolean (ブール)

サブスクライブパターンに一致する内部トピックをサブスクリプションから除外するかどうかを決定します。常に明示的に内部トピックをサブスクライブできます。

true

Auto offset reset (自動オフセットリセット)

Enumeration (列挙)。次のいずれかになります。

  • EARLIEST

  • LATEST

  • ERROR

Kafka に初期オフセットがない場合や、(データの削除などで) 現在のオフセットがサーバーに存在しない場合の処理を決定します。

  • EARLIEST

    自動的に最も早いオフセットにリセットします。

  • LATEST

    自動的に最も遅いオフセットにリセットします。

  • ERROR

    コンシューマーのグループの前のオフセットが見つからない場合、エラーをスローします。

LATEST

Retry Backoff Timeout (再試行バックオフタイムアウト)

Number (数値)

特定のトピックパーティションに対して失敗した要求を再試行するまでの待機時間。これにより、一部の失敗シナリオの緊密なループで繰り返し要求が送信されることを回避できます。

100

Retry Backoff Timeout Time Unit (再試行バックオフタイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Retry Backoff Timeout (再試行バックオフタイムアウト)]​ 項目の時間単位。

MILLISECONDS

Check CRC (CRC をチェック)

Boolean (ブール)

コンシュームされるレコードの CRC32 を自動的にチェックします。これにより、ワイヤーまたはディスク上でメッセージに対するコンシュームが発生しなくなります。このチェックにより、オーバーヘッドが増えるため、非常に高いパフォーマンスが求められる状況では、これを無効にできます。

true

Default receive buffer size (デフォルトの受信バッファサイズ)

Number (数値)

データを読み込むときに使用する TCP 受信バッファのサイズ (​SO_RCVBUF​)。値が ​-1​ の場合、OS のデフォルトが使用されます。このパラメーターはソースレベルで上書きできます。

64

Default receive buffer size unit (デフォルトの受信バッファサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default receive buffer size (デフォルトの受信バッファサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

KB

Default send buffer size (デフォルトの送信バッファサイズ)

Number (数値)

データを送信するときに使用する TCP 送信バッファ (​SO_SNDBUF​) のサイズ。値が ​-1​ の場合、OS のデフォルトが使用されます。このパラメーターはソースレベルで上書きできます。

128

Default send buffer size unit (デフォルトの送信バッファサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default send buffer size (デフォルトの送信バッファサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

KB

Request Timeout (要求タイムアウト)

Number (数値)

クライアントが要求の応答を待機する最大時間。タイムアウトが経過する前に応答を受信できない場合、クライアントは必要に応じて要求を再送信します。再試行回数に達すると要求は失敗します。このパラメーターはソースレベルで上書きできます。

30

Request Timeout Time Unit (要求タイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Request Timeout (要求タイムアウト)]​ 項目の時間単位。このパラメーターはソースレベルで上書きできます。

SECONDS

Default record limit (デフォルトのレコード制限)

Number (数値)

Kafka クラスターへのポーリングコールで返されるレコードの最大数。このパラメーターはソースレベルで上書きできます。

500

DNS Lookups (DNS ルックアップ)

Enumeration (列挙)。次のいずれかになります。

  • DEFAULT

  • USE_ALL_DNS_IPS​

  • RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY

クライアントによる DNS ルックアップの使用方法を制御します。

  • USE_ALL_DNS_IPS​

    ルックアップでホスト名の複数の IP アドレスが返されると、接続に失敗するまですべての IP アドレスへの接続が試行されます。ブートストラップサーバーとアドバタイズサーバーの両方に適用されます。

  • RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY​

    各エントリが解決されて、正規名のリストに展開されます。

USE_ALL_DNS_IPS

Heartbeat interval (ハートビート間隔)

Number (数値)

Kafka のグループ管理機能を使用しているときのコンシューマーコーディネーターへのハートビート間の想定間隔。ハートビートは、コンシューマーのセッションがアクティブなままになっていることを確認したり、新しいコンシューマーがグループに参加したときやグループから脱退したときに再調整を容易にするために使用されます。値は ​session.timeout.ms​ 未満に設定する必要がありますが、通常はその値の 1/3 以下に設定することをお勧めします。通常の再調整の場合、さらに低い値に調整して、想定時間を制御できます。

3

Heartbeat Interval Time Unit (ハートビート間隔時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Heartbeat interval (ハートビート間隔)]​ 項目の時間単位。

SECONDS

Session Timeout (セッションタイムアウト)

Number (数値)

Kafka のグループ管理機能を使用しているときにコンシューマーの失敗を検出するために使用されるタイムアウト。コンシューマーは定期的にハートビートを送信し、生存していることをブローカーに示します。このセッションタイムアウトの期限までにハートビートを受信できない場合、ブローカーはこのコンシューマーをグループから削除し、再調整を開始します。この値は、ブローカー設定の ​group.min.session.timeout.ms​ と ​group.max.session.timeout.ms​ で設定される許容範囲に収まっている必要があります。

10

Session timeout time unit (セッションタイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Session Timeout (セッションタイムアウト)]​ 項目の時間単位。

SECONDS

Connection maximum idle time (最大接続アイドル時間)

Number (数値)

この設定で指定されたミリ秒が経過すると、アイドル接続が終了します。

540

Connection maximum idle time time unit (最大接続アイドル時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Connection maximum idle time (接続の最大アイドル時間)]​ 項目の時間単位。

SECONDS

TLS Configuration (TLS 設定)

TLS

Mule アプリケーションの通信を保護するためにクライアント側とサーバー側の両方で使用される TLS 設定を定義します。コネクタは、通信で使用する ​security.protocol​ を自動的に設定します。有効な値は ​PLAINTEXT​、​SSL​、​SASL_PLAINTEXT​、​SASL_SSL​ です。デフォルト値は ​PLAINTEXT​ または ​SASL_PLAINTEXT​ (SASL 認証 (kerberos/scram/plain) の場合) です。ブローカーで ​SSL​ がプロトコルとして設定されている場合、設定の ​tls:context​ 子要素で少なくともキーストアを設定します。また、コネクタは ​security.protocol​ として ​SSL​ (SASL 認証の場合は ​SASL_SSL​) を自動的に使用します。

Endpoint identification algorithm (エンドポイント識別アルゴリズム)

String (文字列)

クライアントがサーバーのホスト名を検証するために使用するエンドポイント識別アルゴリズム。デフォルト値は空の文字列です。つまり、エンドポイント識別アルゴリズムは無効になっています。クライアント (ブローカーによって作成されたブローカー間の通信のクライアント接続を含む) は、ブローカーのホスト名がブローカーの証明書のホスト名と一致していることを確認します。

Topic Subscription Patterns (トピックサブスクリプションパターン)

Array of String (文字列の配列)

サブスクライブするサブスクリプションの正規表現のリスト。トピックは、トピックコンシューマー間で自動的に再調整されます。

Assignments (割り当て)

Topic Partition (トピックパーティション)​ の配列

割り当てるトピック-パーティションペアのリスト。コンシューマーは自動的に再調整されません。

Default fetch minimum size (デフォルトの最小フェッチサイズ)

Number (数値)

フェッチ要求に対してサーバーが返すデータの最小量。十分なデータを使用できない場合、要求は指定された最小データ量が蓄積されて要求の応答が行われるまで待機します。デフォルトでは ​1​ バイトに設定されています。これは、データの到着を待機したままフェッチ要求がタイムアウトする場合を除き、1 バイトのデータが使用できるようになるとすぐにフェッチ要求の応答が返されることを意味します。これを ​1​ より大きな値に設定すると、サーバーはより大きなデータ量が蓄積されるまで待機します。これにより、レイテンシーは増えますが、サーバーのスループットは若干向上します。このパラメーターはソースレベルで上書きできます。

1

Fetch Minimum Size Unit (最小フェッチサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default fetch minimum size (デフォルトの最小フェッチサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

BYTE

Default fetch maximum size (デフォルトの最大フェッチサイズ)

Number (数値)

フェッチ要求に対してサーバーが返すデータの最大量。コンシューマーは、まとめてレコードをフェッチします。フェッチの最初の空でないパーティションの最初のレコードバッチがこの値より大きい場合でも、コンシューマーが処理を続行できるようにレコードバッチが返されます。そのため、これは絶対最大値ではありません。ブローカーで受け入れられる最大レコードバッチサイズは、​message.max.bytes​ (ブローカー設定) または ​max.message.bytes​ (トピック設定) を使用して定義されます。コンシューマーは複数のフェッチを並列で実行します。このパラメーターはソースレベルで上書きできます。

1

Default maximum fetch size unit (デフォルトの最大フェッチサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default fetch maximum size (デフォルトの最大フェッチサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

MB

Default maximum partition fetch size (デフォルトの最大パーティションフェッチサイズ)

Number (数値)

サーバーが返すパーティションあたりの最大データ量。コンシューマーは、まとめてレコードをフェッチします。フェッチの最初の空でないパーティションの最初のレコードバッチがこの制限より大きい場合でも、コンシューマーが処理を続行できるようにバッチが返されます。ブローカーで受け入れられる最大レコードバッチサイズは、​message.max.bytes​ (ブローカー設定) または ​max.message.bytes​ (トピック設定) を使用して定義されます。コンシューマーの要求サイズの制限については、​fetch.max.bytes​ を参照してください。このパラメーターはソースレベルで上書きできます。

1

Default maximum partition fetch unit (デフォルトの最大パーティションフェッチ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default maximum partition fetch size (デフォルトの最大パーティションフェッチサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

MB

Fetch Maximum Wait Timeout (最大フェッチ待機タイムアウト)

Number (数値)

fetch.min.bytes​ で指定された要件をすぐに満たすだけの十分なデータがない場合のフェッチ要求に応答するまでの最大サーバーブロック時間。

500

Fetch Maximum Wait Timeout Unit (最大フェッチ待機タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Fetch Maximum Wait Timeout (最大フェッチ待機タイムアウト)]​ 項目の時間単位。

MILLISECONDS

Principal (プリンシパル)

String (文字列)

コンピューターシステムまたはネットワークで認証されるエンティティ。プリンシパルは、個人、コンピューター、サービス、計算エンティティ (プロセッサーやスレッドなど) になります。

x

Service name (サービス名)

String (文字列)

Kafka が実行時に使用する Kerberos プリンシパル名。

x

Kerberos 設定ファイル (krb5.conf)

String (文字列)

Kerberos 設定情報が格納されている ​krb5.conf​ ファイルへのパス。この情報には、KDC の場所、目的の Kerberos レルムの管理サーバー、現在のレルムのデフォルト、Kerberos アプリケーションのデフォルト、Kerberos レルムのホスト名のマッピングが含まれます。

Use ticket cache (チケットキャッシュを使用)

Boolean (ブール)

チケットキャッシュからチケット保証チケット (TGT) を取得する場合は、このオプションを ​true​ に設定します。チケットキャッシュを使用しない場合は、このオプションを ​false​ に設定します。コネクタは、次のようにチケットキャッシュを検索します。

  • Solaris および Linux の場合、コネクタは ​/tmp/krb5cc_uid​ を検索します。​uid​ は数値のユーザー識別子です。

  • /tmp/krb5cc_uid​ でチケットキャッシュが使用できない場合や、アプリケーションが Windows プラットフォーム上にある場合、コネクタは ​{user.home}{file.separator}krb5cc_{user.name}​ を検索します。 チケットキャッシュの場所は、​[Ticket cache (チケットキャッシュ)]​ 項目の値を設定して上書きできます。

    Windows 環境では、ファイルチケットキャッシュからチケットを取得できない場合、ローカルセキュリティ機関 (LSA) API を使用してチケット保証チケット (TGT) を取得します。

false

Ticket cache (チケットキャッシュ)

String (文字列)

ユーザーのチケット保証チケット (TGT) が含まれるチケットキャッシュの名前。この値を設定する場合は、​[Use ticket cache (チケットキャッシュを使用)]​ も ​true​ に設定する必要があります。設定しない場合、設定エラーが返されます。

Use keytab (キータブを使用)

Boolean (ブール)

コネクタでキータブからプリンシパルのキーを取得する場合は、このオプションを ​true​ に設定します。この値を設定しない場合、コネクタは Kerberos 設定ファイルを使用してキータブを探します。Kerberos 設定ファイルでキータブが指定されていない場合、コネクタは ​{user.home}{file.separator}krb5.keytab​ ファイルを探します。

false

Keytab (キータブ)

String (文字列)

このオプションには、プリンシパルの秘密鍵を取得するキータブのファイル名を設定します。

Store key (キーを保存)

Boolean (ブール)

プリンシパルのサブジェクトの非公開ログイン情報を保存するには、このオプションを ​true​ に設定します。

false

Reconnection (再接続)

Reconnection (再接続)

コネクタ操作で外部サーバーへの接続に失敗した場合に使用する再接続戦略を設定します。
### [](#consumer-sasl-scram)Consumer SASL/SCRAM (コンシューマー SASL/SCRAM) 接続種別 Salted Challenge Response Authentication Mechanism (SCRAM) または SASL/SCRAM を使用します。これは、PLAIN のようなユーザー名とパスワード認証を実行する従来のメカニズムを使用してセキュリティ上の懸念に対処する SASL メカニズムのファミリーです。Apache Kafka では SCRAM-SHA-256 および SCRAM-SHA-512 がサポートされています。
名前 型 説明 デフォルト値 必須

Bootstrap Server URLs (ブートストラップサーバー URL)

Array of String (文字列の配列)

Kafka クラスターとの接続をブートストラップするサーバーのリスト。これは、使用可能なサーバーの部分的なリストになる場合があります。

x

Group ID (グループ ID)

String (文字列)

この設定を使用するすべての Kafka コンシューマーのデフォルトのグループ ID。

Consumer Amount (コンシューマー数)

Number (数値)

接続で最初に作成されるコンシューマーの数を決定します。

1

Maximum polling interval (最大ポーリング間隔)

Number (数値)

コンシューマーグループ管理を使用するときの poll() の呼び出し間の最大遅延。これにより、コンシューマーが他のレコードをフェッチするまでの許容アイドル時間の上限が設定されます。このタイムアウトの有効期限までに poll() がコールされないと、コンシューマーは失敗したとみなされ、パーティションを別のメンバーに再割り当てするためにグループが再調整されます。null でない ​group.instance.id​ を使用しているコンシューマーがこのタイムアウトに達しても、パーティションはすぐに再割り当てされません。代わりに、コンシューマーはハートビートの送信を停止します。​session.timeout.ms​ の有効期限が切れると、パーティションが再割り当てされます。

300

Maximum Polling Interval Time Unit (最大ポーリング間隔時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Maximum polling interval (最大ポーリング間隔)]​ 項目の時間単位。このパラメーターはソースレベルで上書きできます。

SECONDS

Isolation Level (分離レベル)

Enumeration (列挙)。次のいずれかになります。

  • READ_UNCOMMITTED​

  • READ_COMMITTED

トランザクションとして書き込まれるメッセージの読み取り方法を制御します。

  • READ_COMMITTED​

    consumer.poll()​ では、コミットされたトランザクションメッセージのみが返されます。

  • READ_UNCOMMITTED​

    consumer.poll()​ では、中止されたトランザクションメッセージも含め、すべてのメッセージが返されます。

非トランザクションメッセージは、どちらのモードでも無条件に返されます。メッセージは常にオフセット順に返されます。そのため、​READ_COMMITTED​ モードの場合、​consumer.poll()​ で、開かれている最初のトランザクションよりも 1 つ少ない最終安定オフセット (LSO) までのメッセージのみが返されます。

具体的には、実行中のトランザクションに属するメッセージの後に表示されるメッセージは、関連するトランザクションが完了するまで表示されません。その結果、​READ_COMMITTED​ コンシューマーは、インフライトトランザクションがあるときにハイウォーターマークまで読み取ることができません。さらに、​READ_COMMITTED​ では、​seekToEnd​ メソッドで LSO が返されます。

READ_UNCOMMITTED

Exclude internal topics (内部トピックを除外)

Boolean (ブール)

サブスクライブパターンに一致する内部トピックをサブスクリプションから除外するかどうかを決定します。常に明示的に内部トピックをサブスクライブできます。

true

Auto offset reset (自動オフセットリセット)

Enumeration (列挙)。次のいずれかになります。

  • EARLIEST

  • LATEST

  • ERROR

Kafka に初期オフセットがない場合や、(データの削除などで) 現在のオフセットがサーバーに存在しない場合の処理を決定します。

  • EARLIEST

    自動的に最も早いオフセットにリセットします。

  • LATEST

    自動的に最も遅いオフセットにリセットします。

  • ERROR

    コンシューマーのグループの前のオフセットが見つからない場合、エラーをスローします。

LATEST

Retry Backoff Timeout (再試行バックオフタイムアウト)

Number (数値)

特定のトピックパーティションに対して失敗した要求を再試行するまでの待機時間。これにより、一部の失敗シナリオの緊密なループで繰り返し要求が送信されることを回避できます。

100

Retry Backoff Timeout Time Unit (再試行バックオフタイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Retry Backoff Timeout (再試行バックオフタイムアウト)]​ 項目の時間単位。

MILLISECONDS

Check CRC (CRC をチェック)

Boolean (ブール)

コンシュームされるレコードの CRC32 を自動的にチェックします。これにより、ワイヤーまたはディスク上でメッセージに対するコンシュームが発生しなくなります。このチェックにより、オーバーヘッドが増えるため、非常に高いパフォーマンスが求められる状況では、これを無効にできます。

true

Default receive buffer size (デフォルトの受信バッファサイズ)

Number (数値)

データを読み込むときに使用する TCP 受信バッファのサイズ (​SO_RCVBUF​)。値が ​-1​ の場合、OS のデフォルトが使用されます。このパラメーターはソースレベルで上書きできます。

64

Default receive buffer size unit (デフォルトの受信バッファサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default receive buffer size (デフォルトの受信バッファサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

KB

Default send buffer size (デフォルトの送信バッファサイズ)

Number (数値)

データを送信するときに使用する TCP 送信バッファ (​SO_SNDBUF​) のサイズ。値が ​-1​ の場合、OS のデフォルトが使用されます。このパラメーターはソースレベルで上書きできます。

128

Default send buffer size unit (デフォルトの送信バッファサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default send buffer size (デフォルトの送信バッファサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

KB

Request Timeout (要求タイムアウト)

Number (数値)

クライアントが要求の応答を待機する最大時間。タイムアウトが経過する前に応答を受信できない場合、クライアントは必要に応じて要求を再送信します。再試行回数に達すると要求は失敗します。このパラメーターはソースレベルで上書きできます。

30

Request Timeout Time Unit (要求タイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Request Timeout (要求タイムアウト)]​ 項目の時間単位。このパラメーターはソースレベルで上書きできます。

SECONDS

Default record limit (デフォルトのレコード制限)

Number (数値)

Kafka クラスターへのポーリングコールで返されるレコードの最大数。このパラメーターはソースレベルで上書きできます。

500

DNS Lookups (DNS ルックアップ)

Enumeration (列挙)。次のいずれかになります。

  • DEFAULT

  • USE_ALL_DNS_IPS​

  • RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY

クライアントによる DNS ルックアップの使用方法を制御します。

  • USE_ALL_DNS_IPS​

    ルックアップでホスト名の複数の IP アドレスが返されると、接続に失敗するまですべての IP アドレスへの接続が試行されます。ブートストラップサーバーとアドバタイズサーバーの両方に適用されます。

  • RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY​

    各エントリが解決されて、正規名のリストに展開されます。

USE_ALL_DNS_IPS

Heartbeat interval (ハートビート間隔)

Number (数値)

Kafka のグループ管理機能を使用しているときのコンシューマーコーディネーターへのハートビート間の想定間隔。ハートビートは、コンシューマーのセッションがアクティブなままになっていることを確認したり、新しいコンシューマーがグループに参加したときやグループから脱退したときに再調整を容易にするために使用されます。値は ​session.timeout.ms​ 未満に設定する必要がありますが、通常はその値の 1/3 以下に設定することをお勧めします。通常の再調整の場合、さらに低い値に調整して、想定時間を制御できます。

3

Heartbeat Interval Time Unit (ハートビート間隔時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Heartbeat interval (ハートビート間隔)]​ 項目の時間単位。

SECONDS

Session Timeout (セッションタイムアウト)

Number (数値)

Kafka のグループ管理機能を使用しているときにコンシューマーの失敗を検出するために使用されるタイムアウト。コンシューマーは定期的にハートビートを送信し、生存していることをブローカーに示します。このセッションタイムアウトの期限までにハートビートを受信できない場合、ブローカーはこのコンシューマーをグループから削除し、再調整を開始します。この値は、ブローカー設定の ​group.min.session.timeout.ms​ と ​group.max.session.timeout.ms​ で設定される許容範囲に収まっている必要があります。

10

Session timeout time unit (セッションタイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Session Timeout (セッションタイムアウト)]​ 項目の時間単位。

SECONDS

Connection maximum idle time (最大接続アイドル時間)

Number (数値)

この設定で指定されたミリ秒が経過すると、アイドル接続が終了します。

540

Connection maximum idle time time unit (最大接続アイドル時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Connection maximum idle time (接続の最大アイドル時間)]​ 項目の時間単位。

SECONDS

TLS Configuration (TLS 設定)

TLS

Mule アプリケーションの通信を保護するためにクライアント側とサーバー側の両方で使用される TLS 設定を定義します。コネクタは、通信で使用する ​security.protocol​ を自動的に設定します。有効な値は ​PLAINTEXT​、​SSL​、​SASL_PLAINTEXT​、​SASL_SSL​ です。デフォルト値は ​PLAINTEXT​ または ​SASL_PLAINTEXT​ (SASL 認証 (kerberos/scram/plain) の場合) です。ブローカーで ​SSL​ がプロトコルとして設定されている場合、設定の ​tls:context​ 子要素で少なくともキーストアを設定します。また、コネクタは ​security.protocol​ として ​SSL​ (SASL 認証の場合は ​SASL_SSL​) を自動的に使用します。

Endpoint identification algorithm (エンドポイント識別アルゴリズム)

String (文字列)

クライアントがサーバーのホスト名を検証するために使用するエンドポイント識別アルゴリズム。デフォルト値は空の文字列です。つまり、エンドポイント識別アルゴリズムは無効になっています。クライアント (ブローカーによって作成されたブローカー間の通信のクライアント接続を含む) は、ブローカーのホスト名がブローカーの証明書のホスト名と一致していることを確認します。

Topic Subscription Patterns (トピックサブスクリプションパターン)

Array of String (文字列の配列)

サブスクライブするサブスクリプションの正規表現のリスト。トピックは、トピックコンシューマー間で自動的に再調整されます。

Assignments (割り当て)

Topic Partition (トピックパーティション)​ の配列

割り当てるトピック-パーティションペアのリスト。コンシューマーは自動的に再調整されません。

Default fetch minimum size (デフォルトの最小フェッチサイズ)

Number (数値)

フェッチ要求に対してサーバーが返すデータの最小量。十分なデータを使用できない場合、要求は指定された最小データ量が蓄積されて要求の応答が行われるまで待機します。デフォルトでは ​1​ バイトに設定されています。これは、データの到着を待機したままフェッチ要求がタイムアウトする場合を除き、1 バイトのデータが使用できるようになるとすぐにフェッチ要求の応答が返されることを意味します。これを ​1​ より大きな値に設定すると、サーバーはより大きなデータ量が蓄積されるまで待機します。これにより、レイテンシーは増えますが、サーバーのスループットは若干向上します。このパラメーターはソースレベルで上書きできます。

1

Fetch Minimum Size Unit (最小フェッチサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default fetch minimum size (デフォルトの最小フェッチサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

BYTE

Default fetch maximum size (デフォルトの最大フェッチサイズ)

Number (数値)

フェッチ要求に対してサーバーが返すデータの最大量。コンシューマーは、まとめてレコードをフェッチします。フェッチの最初の空でないパーティションの最初のレコードバッチがこの値より大きい場合でも、コンシューマーが処理を続行できるようにレコードバッチが返されます。そのため、これは絶対最大値ではありません。ブローカーで受け入れられる最大レコードバッチサイズは、​message.max.bytes​ (ブローカー設定) または ​max.message.bytes​ (トピック設定) を使用して定義されます。コンシューマーは複数のフェッチを並列で実行します。このパラメーターはソースレベルで上書きできます。

1

Default maximum fetch size unit (デフォルトの最大フェッチサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default fetch maximum size (デフォルトの最大フェッチサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

MB

Default maximum partition fetch size (デフォルトの最大パーティションフェッチサイズ)

Number (数値)

サーバーが返すパーティションあたりの最大データ量。コンシューマーは、まとめてレコードをフェッチします。フェッチの最初の空でないパーティションの最初のレコードバッチがこの制限より大きい場合でも、コンシューマーが処理を続行できるようにバッチが返されます。ブローカーで受け入れられる最大レコードバッチサイズは、​message.max.bytes​ (ブローカー設定) または ​max.message.bytes​ (トピック設定) を使用して定義されます。コンシューマーの要求サイズの制限については、​fetch.max.bytes​ を参照してください。このパラメーターはソースレベルで上書きできます。

1

Default maximum partition fetch unit (デフォルトの最大パーティションフェッチ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default maximum partition fetch size (デフォルトの最大パーティションフェッチサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

MB

Fetch Maximum Wait Timeout (最大フェッチ待機タイムアウト)

Number (数値)

fetch.min.bytes​ で指定された要件をすぐに満たすだけの十分なデータがない場合のフェッチ要求に応答するまでの最大サーバーブロック時間。

500

Fetch Maximum Wait Timeout Unit (最大フェッチ待機タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Fetch Maximum Wait Timeout (最大フェッチ待機タイムアウト)]​ 項目の時間単位。

MILLISECONDS

Username (ユーザー名)

String (文字列)

ログインで使用するユーザー名。

x

Password (パスワード)

String (文字列)

ログインで使用するパスワード。

x

Encryption type (暗号化種別)

Enumeration (列挙)。次のいずれかになります。

  • SHA256

  • SHA512

SCRAM で使用される暗号化アルゴリズム。

x

Reconnection (再接続)

Reconnection (再接続)

コネクタ操作で外部サーバーへの接続に失敗した場合に使用する再接続戦略を設定します。
### [](#consumer-sasl-plain)Consumer SASL/PLAIN (コンシューマー SASL/PLAIN) 接続種別 ユーザー名とパスワードで認証する SASL を使用します。
名前 型 説明 デフォルト値 必須

Bootstrap Server URLs (ブートストラップサーバー URL)

Array of String (文字列の配列)

Kafka クラスターとの接続をブートストラップするサーバーのリスト。これは、使用可能なサーバーの部分的なリストになる場合があります。

x

Group ID (グループ ID)

String (文字列)

この設定を使用するすべての Kafka コンシューマーのデフォルトのグループ ID。

Consumer Amount (コンシューマー数)

Number (数値)

接続で最初に作成されるコンシューマーの数を決定します。

1

Maximum polling interval (最大ポーリング間隔)

Number (数値)

コンシューマーグループ管理を使用するときの poll() の呼び出し間の最大遅延。これにより、コンシューマーが他のレコードをフェッチするまでの許容アイドル時間の上限が設定されます。このタイムアウトの有効期限までに poll() がコールされないと、コンシューマーは失敗したとみなされ、パーティションを別のメンバーに再割り当てするためにグループが再調整されます。null でない ​group.instance.id​ を使用しているコンシューマーがこのタイムアウトに達しても、パーティションはすぐに再割り当てされません。代わりに、コンシューマーはハートビートの送信を停止します。​session.timeout.ms​ の有効期限が切れると、パーティションが再割り当てされます。

300

Maximum Polling Interval Time Unit (最大ポーリング間隔時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Maximum polling interval (最大ポーリング間隔)]​ 項目の時間単位。このパラメーターはソースレベルで上書きできます。

SECONDS

Isolation Level (分離レベル)

Enumeration (列挙)。次のいずれかになります。

  • READ_UNCOMMITTED​

  • READ_COMMITTED

トランザクションとして書き込まれるメッセージの読み取り方法を制御します。

  • READ_COMMITTED​

    consumer.poll()​ では、コミットされたトランザクションメッセージのみが返されます。

  • READ_UNCOMMITTED​

    consumer.poll()​ では、中止されたトランザクションメッセージも含め、すべてのメッセージが返されます。

非トランザクションメッセージは、どちらのモードでも無条件に返されます。メッセージは常にオフセット順に返されます。そのため、​READ_COMMITTED​ モードの場合、​consumer.poll()​ で、開かれている最初のトランザクションよりも 1 つ少ない最終安定オフセット (LSO) までのメッセージのみが返されます。

具体的には、実行中のトランザクションに属するメッセージの後に表示されるメッセージは、関連するトランザクションが完了するまで表示されません。その結果、​READ_COMMITTED​ コンシューマーは、インフライトトランザクションがあるときにハイウォーターマークまで読み取ることができません。さらに、​READ_COMMITTED​ では、​seekToEnd​ メソッドで LSO が返されます。

READ_UNCOMMITTED

Exclude internal topics (内部トピックを除外)

Boolean (ブール)

サブスクライブパターンに一致する内部トピックをサブスクリプションから除外するかどうかを決定します。常に明示的に内部トピックをサブスクライブできます。

true

Auto offset reset (自動オフセットリセット)

Enumeration (列挙)。次のいずれかになります。

  • EARLIEST

  • LATEST

  • ERROR

Kafka に初期オフセットがない場合や、(データの削除などで) 現在のオフセットがサーバーに存在しない場合の処理を決定します。

  • EARLIEST

    自動的に最も早いオフセットにリセットします。

  • LATEST

    自動的に最も遅いオフセットにリセットします。

  • ERROR

    コンシューマーのグループの前のオフセットが見つからない場合、エラーをスローします。

LATEST

Retry Backoff Timeout (再試行バックオフタイムアウト)

Number (数値)

特定のトピックパーティションに対して失敗した要求を再試行するまでの待機時間。これにより、一部の失敗シナリオの緊密なループで繰り返し要求が送信されることを回避できます。

100

Retry Backoff Timeout Time Unit (再試行バックオフタイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Retry Backoff Timeout (再試行バックオフタイムアウト)]​ 項目の時間単位。

MILLISECONDS

Check CRC (CRC をチェック)

Boolean (ブール)

コンシュームされるレコードの CRC32 を自動的にチェックします。これにより、ワイヤーまたはディスク上でメッセージに対するコンシュームが発生しなくなります。このチェックにより、オーバーヘッドが増えるため、非常に高いパフォーマンスが求められる状況では、これを無効にできます。

true

Default receive buffer size (デフォルトの受信バッファサイズ)

Number (数値)

データを読み込むときに使用する TCP 受信バッファのサイズ (​SO_RCVBUF​)。値が ​-1​ の場合、OS のデフォルトが使用されます。このパラメーターはソースレベルで上書きできます。

64

Default receive buffer size unit (デフォルトの受信バッファサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default receive buffer size (デフォルトの受信バッファサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

KB

Default send buffer size (デフォルトの送信バッファサイズ)

Number (数値)

データを送信するときに使用する TCP 送信バッファ (​SO_SNDBUF​) のサイズ。値が ​-1​ の場合、OS のデフォルトが使用されます。このパラメーターはソースレベルで上書きできます。

128

Default send buffer size unit (デフォルトの送信バッファサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default send buffer size (デフォルトの送信バッファサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

KB

Request Timeout (要求タイムアウト)

Number (数値)

クライアントが要求の応答を待機する最大時間。タイムアウトが経過する前に応答を受信できない場合、クライアントは必要に応じて要求を再送信します。再試行回数に達すると要求は失敗します。このパラメーターはソースレベルで上書きできます。

30

Request Timeout Time Unit (要求タイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Request Timeout (要求タイムアウト)]​ 項目の時間単位。このパラメーターはソースレベルで上書きできます。

SECONDS

Default record limit (デフォルトのレコード制限)

Number (数値)

Kafka クラスターへのポーリングコールで返されるレコードの最大数。このパラメーターはソースレベルで上書きできます。

500

DNS Lookups (DNS ルックアップ)

Enumeration (列挙)。次のいずれかになります。

  • DEFAULT

  • USE_ALL_DNS_IPS​

  • RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY

クライアントによる DNS ルックアップの使用方法を制御します。

  • USE_ALL_DNS_IPS​

    ルックアップでホスト名の複数の IP アドレスが返されると、接続に失敗するまですべての IP アドレスへの接続が試行されます。ブートストラップサーバーとアドバタイズサーバーの両方に適用されます。

  • RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY​

    各エントリが解決されて、正規名のリストに展開されます。

USE_ALL_DNS_IPS

Heartbeat interval (ハートビート間隔)

Number (数値)

Kafka のグループ管理機能を使用しているときのコンシューマーコーディネーターへのハートビート間の想定間隔。ハートビートは、コンシューマーのセッションがアクティブなままになっていることを確認したり、新しいコンシューマーがグループに参加したときやグループから脱退したときに再調整を容易にするために使用されます。値は ​session.timeout.ms​ 未満に設定する必要がありますが、通常はその値の 1/3 以下に設定することをお勧めします。通常の再調整の場合、さらに低い値に調整して、想定時間を制御できます。

3

Heartbeat Interval Time Unit (ハートビート間隔時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Heartbeat interval (ハートビート間隔)]​ 項目の時間単位。

SECONDS

Session Timeout (セッションタイムアウト)

Number (数値)

Kafka のグループ管理機能を使用しているときにコンシューマーの失敗を検出するために使用されるタイムアウト。コンシューマーは定期的にハートビートを送信し、生存していることをブローカーに示します。このセッションタイムアウトの期限までにハートビートを受信できない場合、ブローカーはこのコンシューマーをグループから削除し、再調整を開始します。この値は、ブローカー設定の ​group.min.session.timeout.ms​ と ​group.max.session.timeout.ms​ で設定される許容範囲に収まっている必要があります。

10

Session timeout time unit (セッションタイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Session Timeout (セッションタイムアウト)]​ 項目の時間単位。

SECONDS

Connection maximum idle time (最大接続アイドル時間)

Number (数値)

この設定で指定されたミリ秒が経過すると、アイドル接続が終了します。

540

Connection maximum idle time time unit (最大接続アイドル時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Connection maximum idle time (接続の最大アイドル時間)]​ 項目の時間単位。

SECONDS

TLS Configuration (TLS 設定)

TLS

Mule アプリケーションの通信を保護するためにクライアント側とサーバー側の両方で使用される TLS 設定を定義します。コネクタは、通信で使用する ​security.protocol​ を自動的に設定します。有効な値は ​PLAINTEXT​、​SSL​、​SASL_PLAINTEXT​、​SASL_SSL​ です。デフォルト値は ​PLAINTEXT​ または ​SASL_PLAINTEXT​ (SASL 認証 (kerberos/scram/plain) の場合) です。ブローカーで ​SSL​ がプロトコルとして設定されている場合、設定の ​tls:context​ 子要素で少なくともキーストアを設定します。また、コネクタは ​security.protocol​ として ​SSL​ (SASL 認証の場合は ​SASL_SSL​) を自動的に使用します。

Endpoint identification algorithm (エンドポイント識別アルゴリズム)

String (文字列)

クライアントがサーバーのホスト名を検証するために使用するエンドポイント識別アルゴリズム。デフォルト値は空の文字列です。つまり、エンドポイント識別アルゴリズムは無効になっています。クライアント (ブローカーによって作成されたブローカー間の通信のクライアント接続を含む) は、ブローカーのホスト名がブローカーの証明書のホスト名と一致していることを確認します。

Topic Subscription Patterns (トピックサブスクリプションパターン)

Array of String (文字列の配列)

サブスクライブするサブスクリプションの正規表現のリスト。トピックは、トピックコンシューマー間で自動的に再調整されます。

Assignments (割り当て)

Topic Partition (トピックパーティション)​ の配列

割り当てるトピック-パーティションペアのリスト。コンシューマーは自動的に再調整されません。

Default fetch minimum size (デフォルトの最小フェッチサイズ)

Number (数値)

フェッチ要求に対してサーバーが返すデータの最小量。十分なデータを使用できない場合、要求は指定された最小データ量が蓄積されて要求の応答が行われるまで待機します。デフォルトでは ​1​ バイトに設定されています。これは、データの到着を待機したままフェッチ要求がタイムアウトする場合を除き、1 バイトのデータが使用できるようになるとすぐにフェッチ要求の応答が返されることを意味します。これを ​1​ より大きな値に設定すると、サーバーはより大きなデータ量が蓄積されるまで待機します。これにより、レイテンシーは増えますが、サーバーのスループットは若干向上します。このパラメーターはソースレベルで上書きできます。

1

Fetch Minimum Size Unit (最小フェッチサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default fetch minimum size (デフォルトの最小フェッチサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

BYTE

Default fetch maximum size (デフォルトの最大フェッチサイズ)

Number (数値)

フェッチ要求に対してサーバーが返すデータの最大量。コンシューマーは、まとめてレコードをフェッチします。フェッチの最初の空でないパーティションの最初のレコードバッチがこの値より大きい場合でも、コンシューマーが処理を続行できるようにレコードバッチが返されます。そのため、これは絶対最大値ではありません。ブローカーで受け入れられる最大レコードバッチサイズは、​message.max.bytes​ (ブローカー設定) または ​max.message.bytes​ (トピック設定) を使用して定義されます。コンシューマーは複数のフェッチを並列で実行します。このパラメーターはソースレベルで上書きできます。

1

Default maximum fetch size unit (デフォルトの最大フェッチサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default fetch maximum size (デフォルトの最大フェッチサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

MB

Default maximum partition fetch size (デフォルトの最大パーティションフェッチサイズ)

Number (数値)

サーバーが返すパーティションあたりの最大データ量。コンシューマーは、まとめてレコードをフェッチします。フェッチの最初の空でないパーティションの最初のレコードバッチがこの制限より大きい場合でも、コンシューマーが処理を続行できるようにバッチが返されます。ブローカーで受け入れられる最大レコードバッチサイズは、​message.max.bytes​ (ブローカー設定) または ​max.message.bytes​ (トピック設定) を使用して定義されます。コンシューマーの要求サイズの制限については、​fetch.max.bytes​ を参照してください。このパラメーターはソースレベルで上書きできます。

1

Default maximum partition fetch unit (デフォルトの最大パーティションフェッチ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default maximum partition fetch size (デフォルトの最大パーティションフェッチサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

MB

Fetch Maximum Wait Timeout (最大フェッチ待機タイムアウト)

Number (数値)

fetch.min.bytes​ で指定された要件をすぐに満たすだけの十分なデータがない場合のフェッチ要求に応答するまでの最大サーバーブロック時間。

500

Fetch Maximum Wait Timeout Unit (最大フェッチ待機タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Fetch Maximum Wait Timeout (最大フェッチ待機タイムアウト)]​ 項目の時間単位。

MILLISECONDS

Username (ユーザー名)

String (文字列)

クライアントが Kafka ブローカーに接続するときに使用するユーザー。

x

Password (パスワード)

String (文字列)

クライアントが Kafka ブローカーに接続するときに使用するパスワード。

x

Reconnection (再接続)

Reconnection (再接続)

コネクタ操作で外部サーバーへの接続に失敗した場合に使用する再接続戦略を設定します。
### [](#consumer-config_consumer-sasl-token-connection)Consumer SASL/TOKEN (コンシューマー SASL/TOKEN) 接続種別 委任トークンを使用して Kafka クラスターに認証します。
セキュリティ上の理由により、最初の認証で委任トークンが使用されている場合、委任トークンは更新できません。詳細は、 「Delegation Token Support for Kafka (Kafka の委任トークンサポート)」​を参照してください。
名前 型 説明 デフォルト値 必須

Bootstrap Server URLs (ブートストラップサーバー URL)

Array of String (文字列の配列)

Kafka クラスターとの接続をブートストラップするサーバーのリスト。これは、使用可能なサーバーの部分的なリストになる場合があります。

x

Group ID (グループ ID)

String (文字列)

この設定を使用するすべての Kafka コンシューマーのデフォルトのグループ ID。

Consumer Amount (コンシューマー数)

Number (数値)

接続で最初に作成されるコンシューマーの数を決定します。

1

Maximum polling interval (最大ポーリング間隔)

Number (数値)

コンシューマーグループ管理を使用するときの poll() の呼び出し間の最大遅延。これにより、コンシューマーが他のレコードをフェッチするまでの許容アイドル時間の上限が設定されます。このタイムアウトの有効期限までに poll() がコールされないと、コンシューマーは失敗したとみなされ、パーティションを別のメンバーに再割り当てするためにグループが再調整されます。null でない ​group.instance.id​ を使用しているコンシューマーがこのタイムアウトに達しても、パーティションはすぐに再割り当てされません。代わりに、コンシューマーはハートビートの送信を停止します。​session.timeout.ms​ の有効期限が切れると、パーティションが再割り当てされます。

300

Maximum Polling Interval Time Unit (最大ポーリング間隔時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Maximum polling interval (最大ポーリング間隔)]​ 項目の時間単位。このパラメーターはソースレベルで上書きできます。

SECONDS

Isolation Level (分離レベル)

Enumeration (列挙)。次のいずれかになります。

  • READ_UNCOMMITTED​

  • READ_COMMITTED

トランザクションとして書き込まれるメッセージの読み取り方法を制御します。

  • READ_COMMITTED​

    consumer.poll()​ では、コミットされたトランザクションメッセージのみが返されます。

  • READ_UNCOMMITTED​

    consumer.poll()​ では、中止されたトランザクションメッセージも含め、すべてのメッセージが返されます。

非トランザクションメッセージは、どちらのモードでも無条件に返されます。メッセージは常にオフセット順に返されます。そのため、​READ_COMMITTED​ モードの場合、​consumer.poll()​ で、開かれている最初のトランザクションよりも 1 つ少ない最終安定オフセット (LSO) までのメッセージのみが返されます。

具体的には、実行中のトランザクションに属するメッセージの後に表示されるメッセージは、関連するトランザクションが完了するまで表示されません。その結果、​READ_COMMITTED​ コンシューマーは、インフライトトランザクションがあるときにハイウォーターマークまで読み取ることができません。さらに、​READ_COMMITTED​ では、​seekToEnd​ メソッドで LSO が返されます。

READ_UNCOMMITTED

Exclude internal topics (内部トピックを除外)

Boolean (ブール)

サブスクライブパターンに一致する内部トピックをサブスクリプションから除外するかどうかを決定します。常に明示的に内部トピックをサブスクライブできます。

true

Auto offset reset (自動オフセットリセット)

Enumeration (列挙)。次のいずれかになります。

  • EARLIEST

  • LATEST

  • ERROR

Kafka に初期オフセットがない場合や、(データの削除などで) 現在のオフセットがサーバーに存在しない場合の処理を決定します。

  • EARLIEST

    自動的に最も早いオフセットにリセットします。

  • LATEST

    自動的に最も遅いオフセットにリセットします。

  • ERROR

    コンシューマーのグループの前のオフセットが見つからない場合、エラーをスローします。

LATEST

Retry Backoff Timeout (再試行バックオフタイムアウト)

Number (数値)

特定のトピックパーティションに対して失敗した要求を再試行するまでの待機時間。これにより、一部の失敗シナリオの緊密なループで繰り返し要求が送信されることを回避できます。

100

Retry Backoff Timeout Time Unit (再試行バックオフタイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Retry Backoff Timeout (再試行バックオフタイムアウト)]​ 項目の時間単位。

MILLISECONDS

Check CRC (CRC をチェック)

Boolean (ブール)

コンシュームされるレコードの CRC32 を自動的にチェックします。これにより、ワイヤーまたはディスク上でメッセージに対するコンシュームが発生しなくなります。このチェックにより、オーバーヘッドが増えるため、非常に高いパフォーマンスが求められる状況では、これを無効にできます。

true

Default receive buffer size (デフォルトの受信バッファサイズ)

Number (数値)

データを読み込むときに使用する TCP 受信バッファのサイズ (​SO_RCVBUF​)。値が ​-1​ の場合、OS のデフォルトが使用されます。このパラメーターはソースレベルで上書きできます。

64

Default receive buffer size unit (デフォルトの受信バッファサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default receive buffer size (デフォルトの受信バッファサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

KB

Default send buffer size (デフォルトの送信バッファサイズ)

Number (数値)

データを送信するときに使用する TCP 送信バッファ (​SO_SNDBUF​) のサイズ。値が ​-1​ の場合、OS のデフォルトが使用されます。このパラメーターはソースレベルで上書きできます。

128

Default send buffer size unit (デフォルトの送信バッファサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default send buffer size (デフォルトの送信バッファサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

KB

Request Timeout (要求タイムアウト)

Number (数値)

クライアントが要求の応答を待機する最大時間。タイムアウトが経過する前に応答を受信できない場合、クライアントは必要に応じて要求を再送信します。再試行回数に達すると要求は失敗します。このパラメーターはソースレベルで上書きできます。

30

Request Timeout Time Unit (要求タイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Request Timeout (要求タイムアウト)]​ 項目の時間単位。このパラメーターはソースレベルで上書きできます。

SECONDS

Default record limit (デフォルトのレコード制限)

Number (数値)

Kafka クラスターへのポーリングコールで返されるレコードの最大数。このパラメーターはソースレベルで上書きできます。

500

DNS Lookups (DNS ルックアップ)

Enumeration (列挙)。次のいずれかになります。

  • DEFAULT

  • USE_ALL_DNS_IPS​

  • RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY

クライアントによる DNS ルックアップの使用方法を制御します。

  • USE_ALL_DNS_IPS​

    ルックアップでホスト名の複数の IP アドレスが返されると、接続に失敗するまですべての IP アドレスへの接続が試行されます。ブートストラップサーバーとアドバタイズサーバーの両方に適用されます。

  • RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY​

    各エントリが解決されて、正規名のリストに展開されます。

USE_ALL_DNS_IPS

Heartbeat interval (ハートビート間隔)

Number (数値)

Kafka のグループ管理機能を使用しているときのコンシューマーコーディネーターへのハートビート間の想定間隔。ハートビートは、コンシューマーのセッションがアクティブなままになっていることを確認したり、新しいコンシューマーがグループに参加したときやグループから脱退したときに再調整を容易にするために使用されます。値は ​session.timeout.ms​ 未満に設定する必要がありますが、通常はその値の 1/3 以下に設定することをお勧めします。通常の再調整の場合、さらに低い値に調整して、想定時間を制御できます。

3

Heartbeat Interval Time Unit (ハートビート間隔時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Heartbeat interval (ハートビート間隔)]​ 項目の時間単位。

SECONDS

Session Timeout (セッションタイムアウト)

Number (数値)

Kafka のグループ管理機能を使用しているときにコンシューマーの失敗を検出するために使用されるタイムアウト。コンシューマーは定期的にハートビートを送信し、生存していることをブローカーに示します。このセッションタイムアウトの期限までにハートビートを受信できない場合、ブローカーはこのコンシューマーをグループから削除し、再調整を開始します。この値は、ブローカー設定の ​group.min.session.timeout.ms​ と ​group.max.session.timeout.ms​ で設定される許容範囲に収まっている必要があります。

10

Session timeout time unit (セッションタイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Session Timeout (セッションタイムアウト)]​ 項目の時間単位。

SECONDS

Connection maximum idle time (最大接続アイドル時間)

Number (数値)

この設定で指定されたミリ秒が経過すると、アイドル接続が終了します。

540

Connection maximum idle time time unit (最大接続アイドル時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Connection maximum idle time (接続の最大アイドル時間)]​ 項目の時間単位。

SECONDS

TLS Configuration (TLS 設定)

TLS

Mule アプリケーションの通信を保護するためにクライアント側とサーバー側の両方で使用される TLS 設定を定義します。コネクタは、通信で使用する ​security.protocol​ を自動的に設定します。有効な値は ​PLAINTEXT​、​SSL​、​SASL_PLAINTEXT​、​SASL_SSL​ です。デフォルト値は ​PLAINTEXT​ または ​SASL_PLAINTEXT​ (SASL 認証 (kerberos/scram/plain) の場合) です。ブローカーで ​SSL​ がプロトコルとして設定されている場合、設定の ​tls:context​ 子要素で少なくともキーストアを設定します。また、コネクタは ​security.protocol​ として ​SSL​ (SASL 認証の場合は ​SASL_SSL​) を自動的に使用します。

Endpoint identification algorithm (エンドポイント識別アルゴリズム)

String (文字列)

クライアントがサーバーのホスト名を検証するために使用するエンドポイント識別アルゴリズム。デフォルト値は空の文字列です。つまり、エンドポイント識別アルゴリズムは無効になっています。クライアント (ブローカーによって作成されたブローカー間の通信のクライアント接続を含む) は、ブローカーのホスト名がブローカーの証明書のホスト名と一致していることを確認します。

Topic Subscription Patterns (トピックサブスクリプションパターン)

Array of String (文字列の配列)

サブスクライブするサブスクリプションの正規表現のリスト。トピックは、トピックコンシューマー間で自動的に再調整されます。

Assignments (割り当て)

Topic Partition (トピックパーティション)​ の配列

割り当てるトピック-パーティションペアのリスト。コンシューマーは自動的に再調整されません。

Default fetch minimum size (デフォルトの最小フェッチサイズ)

Number (数値)

フェッチ要求に対してサーバーが返すデータの最小量。十分なデータを使用できない場合、要求は指定された最小データ量が蓄積されて要求の応答が行われるまで待機します。デフォルトでは ​1​ バイトに設定されています。これは、データの到着を待機したままフェッチ要求がタイムアウトする場合を除き、1 バイトのデータが使用できるようになるとすぐにフェッチ要求の応答が返されることを意味します。これを ​1​ より大きな値に設定すると、サーバーはより大きなデータ量が蓄積されるまで待機します。これにより、レイテンシーは増えますが、サーバーのスループットは若干向上します。このパラメーターはソースレベルで上書きできます。

1

Fetch Minimum Size Unit (最小フェッチサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default fetch minimum size (デフォルトの最小フェッチサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

BYTE

Default fetch maximum size (デフォルトの最大フェッチサイズ)

Number (数値)

フェッチ要求に対してサーバーが返すデータの最大量。コンシューマーは、まとめてレコードをフェッチします。フェッチの最初の空でないパーティションの最初のレコードバッチがこの値より大きい場合でも、コンシューマーが処理を続行できるようにレコードバッチが返されます。そのため、これは絶対最大値ではありません。ブローカーで受け入れられる最大レコードバッチサイズは、​message.max.bytes​ (ブローカー設定) または ​max.message.bytes​ (トピック設定) を使用して定義されます。コンシューマーは複数のフェッチを並列で実行します。このパラメーターはソースレベルで上書きできます。

1

Default maximum fetch size unit (デフォルトの最大フェッチサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default fetch maximum size (デフォルトの最大フェッチサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

MB

Default maximum partition fetch size (デフォルトの最大パーティションフェッチサイズ)

Number (数値)

サーバーが返すパーティションあたりの最大データ量。コンシューマーは、まとめてレコードをフェッチします。フェッチの最初の空でないパーティションの最初のレコードバッチがこの制限より大きい場合でも、コンシューマーが処理を続行できるようにバッチが返されます。ブローカーで受け入れられる最大レコードバッチサイズは、​message.max.bytes​ (ブローカー設定) または ​max.message.bytes​ (トピック設定) を使用して定義されます。コンシューマーの要求サイズの制限については、​fetch.max.bytes​ を参照してください。このパラメーターはソースレベルで上書きできます。

1

Default maximum partition fetch unit (デフォルトの最大パーティションフェッチ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default maximum partition fetch size (デフォルトの最大パーティションフェッチサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

MB

Fetch Maximum Wait Timeout (最大フェッチ待機タイムアウト)

Number (数値)

fetch.min.bytes​ で指定された要件をすぐに満たすだけの十分なデータがない場合のフェッチ要求に応答するまでの最大サーバーブロック時間。

500

Fetch Maximum Wait Timeout Unit (最大フェッチ待機タイムアウト単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Fetch Maximum Wait Timeout (最大フェッチ待機タイムアウト)]​ 項目の時間単位。

MILLISECONDS

Token ID (トークン ID)

String (文字列)

トークンの ID。

x

Token HMAC (トークン HMAC)

String (文字列)

トークン HAMC。

x

Encryption type (暗号化種別)

Enumeration (列挙)。次のいずれかになります。

  • SCRAM_SHA_256​

  • SCRAM_SHA_512

SCRAM で使用される暗号化アルゴリズム。

x

Reconnection (再接続)

Reconnection (再接続)

コネクタ操作で外部サーバーへの接続に失敗した場合に使用する再接続戦略を設定します。
* * * ## [](#producer-config)プロデューサー設定 Apache Kafka Connector のプロデューサーの設定。
名前 型 説明 デフォルト値 必須

Name (名前)

String (文字列)

この設定の名前。コネクタはこの名前の設定を参照します。

x

Connection (接続)

この設定の接続種別。

x

Default topic (デフォルトトピック)

String (文字列)

プロデューサーの操作で使用するデフォルトピック名。操作の設定レベルで上書きできます。

defaultTopicName

Zone ID (ゾーン ID)

String (文字列)

結果で指定のタイムスタンプを ​ZonedLocalDateTimes​ に変換します。デフォルト値は、システムによって提供されます。

Expiration Policy (有効期限ポリシー)

Expiration Policy (有効期限ポリシー)

動的設定インスタンスがアイドル状態を続けられる最小時間を設定します。この時間が経過すると、Mule Runtime で期限切れに相当するとみなされます。
### [](#producer-plaintext)Producer Plaintext (プロデューサープレーンテキスト) 接続種別 未認証の暗号化されていない接続種別を使用します。
名前 型 説明 デフォルト値 必須

Bootstrap Server URLs (ブートストラップサーバー URL)

Array of String (文字列の配列)

Kafka クラスターとの接続をブートストラップするサーバーのリスト。これは、使用可能なサーバーの部分的なリストになる場合があります。

x

Batch size (バッチサイズ)

Number (数値)

複数のレコードが同じパーティションに送信される場合、プロデューサーはレコードをまとめて要求を少なくしようとします。これは、クライアントとサーバーの両方のパフォーマンスに寄与します。この設定では、デフォルトのバッチサイズをバイト単位で制御します。このサイズより大きなレコードはまとめられません。ブローカーに送信される要求には、送信可能なデータが含まれる複数のバッチがあり、1 つのバッチは各パーティションに対応します。バッチサイズが小さいと、一括処理の頻度が少なくなり、スループットが低下する可能性があります。バッチサイズが ​0​ の場合、一括処理は完全に無効になります。レコードが追加されることを想定して指定のバッチサイズのバッファが常に割り当てられるため、バッチサイズが非常に大きいと、無駄に使用されるメモリが増加する可能性があります。

16

The batch size unit of measure (バッチサイズの測定単位)。

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Batch size (バッチサイズ)]​ 項目の測定単位。

KB

Buffer size (バッファサイズ)

Number (数値)

サーバーへの送信を待機しているレコードをバッファするためにプロデューサーが使用するメモリの合計バイト。レコードがサーバーに配信される前に送信されると、プロデューサーは ​max.block.ms​ の間ブロックされ、この期間が経過すると例外がスローされます。通常、この設定はプロデューサーが使用する合計メモリに対応しますが、プロデューサーが使用するメモリはバッファに使用されないこともあるため、この設定は正確ではありません。一部の追加メモリは、圧縮 (有効になっている場合) やインフライト要求の管理に使用されます。Apache Kafka ドキュメントのデフォルト値は ​33554432​ (32MB) ですが、CloudHub (v0.1 コア) の Mule インスタンスの想定値に合わせてこれに上限を設定する必要があります。

1

The buffer memory size unit of measure (バッファメモリサイズの測定単位)。

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Buffer size (バッファサイズ)]​ 項目の測定単位。

KB

DNS Lookups (DNS ルックアップ)

Enumeration (列挙)。次のいずれかになります。

  • DEFAULT

  • USE_ALL_DNS_IPS​

  • RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY

クライアントによる DNS ルックアップの使用方法を制御します。

  • USE_ALL_DNS_IPS​

    ルックアップでホスト名の複数の IP アドレスが返されると、接続に失敗するまですべての IP アドレスへの接続が試行されます。ブートストラップサーバーとアドバタイズサーバーの両方に適用されます。

  • RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY​

    各エントリが解決されて、正規名のリストに展開されます。

USE_ALL_DNS_IPS

Compression type (圧縮種別)

Enumeration (列挙)。次のいずれかになります。

  • None (なし)

  • GZIP

  • SNAPPY

  • LZ4

  • ZSTD

プロデューサーによって生成されるすべてのデータの圧縮種別。デフォルトは ​NONE​ (圧縮なし) です。圧縮は、データのバッチ全体に対して実行されるため、一括処理の効率性も圧縮率に影響します。一括処理の量が多いほど、圧縮率が高くなります。

NONE

Connections maximum idle time (最大接続アイドル時間)

Number (数値)

指定された時間に達すると、アイドル接続が終了します。

540

Connections maximum idle time unit (最大接続アイドル時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Connections maximum idle time (接続の最大アイドル時間)]​ 項目の時間単位。

SECONDS

Delivery Timeout (配信タイムアウト)

Number (数値)

send()​ へのコールが返されてから成功または失敗をレポートするまでの時間の上限。これにより、レコードの送信前の合計遅延時間、ブローカーからの肯定応答を待機する時間 (必要な場合)、失敗した送信を再試行できる時間が制限されます。回復不能なエラーが発生した場合、再試行回数に達した場合、以前の配信期限に達したバッチにレコードが追加された場合、プロデューサーは、この設定以内にレコードを送信できなかったことをレポートする可能性があります。この設定の値は、​request.timeout.ms​ と ​linger.ms​ の合計以上にする必要があります。

120

Delivery Timeout Time Unit (配信タイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Delivery Timeout (配信タイムアウト)]​ 項目の時間単位。

SECONDS

Enable idempotence (冪等性を有効化)

Boolean (ブール)

true​ に設定すると、プロデューサーはメッセージごとに 1 つのコピーストリームに書き込まれるようにします。​false​ の場合、プロデューサーはブローカーの失敗により再試行するため、再試行されたメッセージが重複してストリームに書き込まれる可能性があります。冪等性を有効にする場合、​max.in.flight.requests.per.connection​ を ​5​ 以下、再試行回数を ​0​ より大きく、肯定応答を ​all​ にする必要があります。ユーザーがこれらの値を明示的に設定しない場合、適切な値が選択されます。互換性のない値が設定されると、​ConnectionException​ がスローされます。

false

Linger time (延長時間)

Number (数値)

プロデューサーは、要求トランスミッション間に到着するレコードを 1 つのバッチ要求にグループ化します。通常、これは負荷時 (レコードが送信される前に到着する場合) にのみ発生します。ただし、クライアントはそれほど負荷がかかっていなくても要求の数を削減したい場合があります。

この設定では、人為的にわずかに遅延させることでこれを実現します。プロデューサーは、送信をまとめることができるようにレコードをすぐに送信せずに指定された遅延が経過するまで待機し、他のレコードの送信を許可します。これは TCP の Nagle アルゴリズムに似ています。この設定により、一括処理の遅延に上限が設定されます。

パーティションで指定された ​batch.size​ 分のレコードを受信すると、この設定に関係なくすぐに送信されます。ただし、このパーティションで指定された蓄積バイト数よりも受信バイト数が少ないと、プロデューサーは指定された時間だけ「延長」して、他のレコードが到着するまで待機します。

この設定のデフォルトは ​0​ (遅延なし) です。たとえば、​linger.ms=5​ を設定すると、送信される要求数は減りますが、負荷がないときに送信されたレコードにも 5ms のレイテンシーが追加されます。

0

Linger Time Unit (延長時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Linger time (延長時間)]​ 項目の時間単位。

SECONDS

Maximum block time (最大ブロック時間)

Number (数値)

KafkaProducer.send()​ および ​KafkaProducer.partitionsFor()​ をブロックする時間を制御します。これらのメソッドは、バッファがフルの場合や、ユーザー指定のシリアライザーまたはパーティショナーのメタデータ ​unavailable.Blocking​ がこのタイムアウトに対して考慮されない場合にブロックされる可能性があります。

60

Maximum block time unit (最大ブロック時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Maximum block time (最大ブロック時間)]​ 項目の時間単位。

SECONDS

Maximum in flight requests (最大インフライト要求)

Number (数値)

ブロックされる前に 1 つの接続でクライアントが送信する肯定応答されていない要求最大数。値が ​1​ より大きく、失敗した送信があると、再試行 (有効になっている場合) によってメッセージが並び替えられる可能性があります。

5

Maximum request size (最大要求サイズ)

Number (数値)

要求の最大サイズ (バイト)。この設定により、プロデューサーが 1 つの要求で送信するレコードバッチ数が制限され、大きな要求が送信されなくなります。また、これは実質的に最大レコードバッチサイズの上限になります。サーバーのレコードバッチサイズの上限がこれとは異なる場合もあります。

1

Maximum request size unit (最大要求サイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Maximum request size (最大要求サイズ)]​ 項目の測定単位。

MB

Producer Acknowledge Mode (プロデューサー肯定応答モード)

Enumeration (列挙)。次のいずれかになります。

  • None (なし)

  • LEADER_ONLY​

  • ALL (すべて)

プロデューサーで要求が完了したとみなされるためにリーダーが受信する必要のある肯定応答の数。この設定では、送信されるレコードの永続性を制御します。

NONE

Default receive buffer size (デフォルトの受信バッファサイズ)

Number (数値)

データを読み込むときに使用する TCP 受信バッファのサイズ (​SO_RCVBUF​)。値が ​-1​ の場合、OS のデフォルトが使用されます。このパラメーターはソースレベルで上書きできます。

64

Default receive buffer size unit (デフォルトの受信バッファサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default receive buffer size (デフォルトの受信バッファサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

KB

Retries amount (再試行回数)

Number (数値)

0​ より大きな値を設定すると、クライアントは一時的なエラーが発生した可能性があるために送信に失敗したレコードを再送信します。この再試行は、エラーが発生したときにクライアントがレコードを再送信する場合と同じです。​max.in.flight.requests.per.connection​ を ​1​ に設定せずに再試行できるようにすると、レコードの順序が変更される可能性があります。これは、2 つのバッチが 1 つのパーティションに送信された場合、最初のバッチが失敗して再試行され、2 番目のバッチが成功すると、2 番目のバッチのレコードが最初に表示される可能性があるためです。また、肯定応答に成功する前に ​delivery.timeout.ms​ で設定されたタイムアウトの期限が切れると、プロデューサーの要求は再試行回数に達する前に失敗します。ユーザーはこれを未設定のままにして、代わりに ​delivery.timeout.ms​ を使用して再試行の動作を制御することをお勧めします。

1

Retry Backoff Timeout (再試行バックオフタイムアウト)

Number (数値)

特定のトピックパーティションに対して失敗した要求を再試行するまでの待機時間。これにより、一部の失敗シナリオの緊密なループで繰り返し要求が送信されることを回避できます。

100

Retry Backoff Timeout Time Unit (再試行バックオフタイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Retry Backoff Timeout (再試行バックオフタイムアウト)]​ 項目の時間単位。

MILLISECONDS

Default send buffer size (デフォルトの送信バッファサイズ)

Number (数値)

データを送信するときに使用する TCP 送信バッファ (​SO_SNDBUF​) のサイズ。値が ​-1​ の場合、OS のデフォルトが使用されます。このパラメーターはソースレベルで上書きできます。

128

Default send buffer size unit (デフォルトの送信バッファサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default send buffer size (デフォルトの送信バッファサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

KB

Default request timeout (デフォルトの要求タイムアウト)

Number (数値)

クライアントが要求の応答を待機する最大時間。タイムアウトが経過する前に応答を受信できない場合、クライアントは必要に応じて要求を再送信します。再試行回数に達すると要求は失敗します。この値は、プロデューサーの不要な再試行によるメッセージの重複の可能性を下げるために ​replica.lag.time.max.ms​ (ブローカー設定) よりも長くする必要があります。

30

Default request timeout time unit (デフォルトの要求タイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Default request timeout (デフォルトの要求タイムアウト)]​ 項目の時間単位。

SECONDS

Partitioner (パーティショナー)

Enumeration (列挙)。次のいずれかになります。

  • DEFAULT

  • ROUND_ROBIN​

  • UNIFORM_STICKY

パーティション分割戦略を制御します。

DEFAULT

TLS Configuration (TLS 設定)

TLS

Mule アプリケーションの通信を保護するためにクライアント側とサーバー側の両方で、使用される TLS 設定を定義します。コネクタは、通信で使用する ​security.protocol​ を自動的に設定します。有効な値は ​PLAINTEXT​、​SSL​、​SASL_PLAINTEXT​、​SASL_SSL​ です。ブローカーで ​SSL​ がプロトコルとして設定されている場合、設定の ​tls:context​ 子要素でキーストアを設定します。また、コネクタは ​security.protocol​ として ​SSL​ (SASL 認証の場合は ​SASL_SSL​) を自動的に使用します。

Endpoint identification algorithm (エンドポイント識別アルゴリズム)

String (文字列)

クライアントがサーバーのホスト名を検証するために使用するエンドポイント識別アルゴリズム。デフォルト値は空の文字列です。つまり、エンドポイント識別アルゴリズムは無効になっています。クライアント (ブローカーによって作成されたブローカー間の通信のクライアント接続を含む) は、ブローカーのホスト名がブローカーの証明書のホスト名と一致していることを確認します。

Reconnection (再接続)

Reconnection (再接続)

コネクタ操作で外部サーバーへの接続に失敗した場合に使用する再接続戦略を設定します。
### [](#producer-sasl-kerberos)Producer Kerberos (プロデューサー Kerberos) 接続種別 Kerberos 設定ファイルを使用します。
名前 型 説明 デフォルト値 必須

Bootstrap Server URLs (ブートストラップサーバー URL)

Array of String (文字列の配列)

Kafka クラスターとの接続をブートストラップするサーバーのリスト。これは、使用可能なサーバーの部分的なリストになる場合があります。

x

Batch size (バッチサイズ)

Number (数値)

複数のレコードが同じパーティションに送信される場合、プロデューサーはレコードをまとめて要求を少なくしようとします。これは、クライアントとサーバーの両方のパフォーマンスに寄与します。この設定では、デフォルトのバッチサイズをバイト単位で制御します。このサイズより大きなレコードはまとめられません。ブローカーに送信される要求には、送信可能なデータが含まれる複数のバッチがあり、1 つのバッチは各パーティションに対応します。バッチサイズが小さいと、一括処理の頻度が少なくなり、スループットが低下する可能性があります。バッチサイズが ​0​ の場合、一括処理は完全に無効になります。レコードが追加されることを想定して指定のバッチサイズのバッファが常に割り当てられるため、バッチサイズが非常に大きいと、無駄に使用されるメモリが増加する可能性があります。

16

The batch size unit of measure (バッチサイズの測定単位)。

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Batch size (バッチサイズ)]​ 項目の測定単位。

KB

Buffer size (バッファサイズ)

Number (数値)

サーバーへの送信を待機しているレコードをバッファするためにプロデューサーが使用するメモリの合計バイト。レコードがサーバーに配信される前に送信されると、プロデューサーは ​max.block.ms​ の間ブロックされ、この期間が経過すると例外がスローされます。通常、この設定はプロデューサーが使用する合計メモリに対応しますが、プロデューサーが使用するメモリはバッファに使用されないこともあるため、この設定は正確ではありません。一部の追加メモリは、圧縮 (有効になっている場合) やインフライト要求の管理に使用されます。Apache Kafka ドキュメントのデフォルト値は ​33554432​ (32MB) ですが、CloudHub (v0.1 コア) の Mule インスタンスの想定値に合わせてこれに上限を設定する必要があります。

1

The buffer memory size unit of measure (バッファメモリサイズの測定単位)。

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Buffer size (バッファサイズ)]​ 項目の測定単位。

KB

DNS Lookups (DNS ルックアップ)

Enumeration (列挙)。次のいずれかになります。

  • DEFAULT

  • USE_ALL_DNS_IPS​

  • RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY

クライアントによる DNS ルックアップの使用方法を制御します。

  • USE_ALL_DNS_IPS​

    ルックアップでホスト名の複数の IP アドレスが返されると、接続に失敗するまですべての IP アドレスへの接続が試行されます。ブートストラップサーバーとアドバタイズサーバーの両方に適用されます。

  • RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY​

    各エントリが解決されて、正規名のリストに展開されます。

USE_ALL_DNS_IPS

Compression type (圧縮種別)

Enumeration (列挙)。次のいずれかになります。

  • None (なし)

  • GZIP

  • SNAPPY

  • LZ4

  • ZSTD

プロデューサーによって生成されるすべてのデータの圧縮種別。デフォルトは ​NONE​ (圧縮なし) です。圧縮は、データのバッチ全体に対して実行されるため、一括処理の効率性も圧縮率に影響します。一括処理の量が多いほど、圧縮率が高くなります。

NONE

Connections maximum idle time (最大接続アイドル時間)

Number (数値)

指定された時間に達すると、アイドル接続が終了します。

540

Connections maximum idle time unit (最大接続アイドル時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Connections maximum idle time (接続の最大アイドル時間)]​ 項目の時間単位。

SECONDS

Delivery Timeout (配信タイムアウト)

Number (数値)

send()​ へのコールが返されてから成功または失敗をレポートするまでの時間の上限。これにより、レコードの送信前の合計遅延時間、ブローカーからの肯定応答を待機する時間 (必要な場合)、失敗した送信を再試行できる時間が制限されます。回復不能なエラーが発生した場合、再試行回数に達した場合、以前の配信期限に達したバッチにレコードが追加された場合、プロデューサーは、この設定以内にレコードを送信できなかったことをレポートする可能性があります。この設定の値は、​request.timeout.ms​ と ​linger.ms​ の合計以上にする必要があります。

120

Delivery Timeout Time Unit (配信タイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Delivery Timeout (配信タイムアウト)]​ 項目の時間単位。

SECONDS

Enable idempotence (冪等性を有効化)

Boolean (ブール)

true​ に設定すると、プロデューサーはメッセージごとに 1 つのコピーストリームに書き込まれるようにします。​false​ の場合、プロデューサーはブローカーの失敗により再試行するため、再試行されたメッセージが重複してストリームに書き込まれる可能性があります。冪等性を有効にする場合、​max.in.flight.requests.per.connection​ を ​5​ 以下、再試行回数を ​0​ より大きく、肯定応答を ​all​ にする必要があります。ユーザーがこれらの値を明示的に設定しない場合、適切な値が選択されます。互換性のない値が設定されると、​ConnectionException​ がスローされます。

false

Linger time (延長時間)

Number (数値)

プロデューサーは、要求トランスミッション間に到着するレコードを 1 つのバッチ要求にグループ化します。通常、これは負荷時 (レコードが送信される前に到着する場合) にのみ発生します。ただし、クライアントはそれほど負荷がかかっていなくても要求の数を削減したい場合があります。

この設定では、人為的にわずかに遅延させることでこれを実現します。プロデューサーは、送信をまとめることができるようにレコードをすぐに送信せずに指定された遅延が経過するまで待機し、他のレコードの送信を許可します。これは TCP の Nagle アルゴリズムに似ています。この設定により、一括処理の遅延に上限が設定されます。

パーティションで指定された ​batch.size​ 分のレコードを受信すると、この設定に関係なくすぐに送信されます。ただし、このパーティションで指定された蓄積バイト数よりも受信バイト数が少ないと、プロデューサーは指定された時間だけ「延長」して、他のレコードが到着するまで待機します。

この設定のデフォルトは ​0​ (遅延なし) です。たとえば、​linger.ms=5​ を設定すると、送信される要求数は減りますが、負荷がないときに送信されたレコードにも 5ms のレイテンシーが追加されます。

0

Linger Time Unit (延長時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Linger time (延長時間)]​ 項目の時間単位。

SECONDS

Maximum block time (最大ブロック時間)

Number (数値)

KafkaProducer.send()​ および ​KafkaProducer.partitionsFor()​ をブロックする時間を制御します。これらのメソッドは、バッファがフルの場合や、ユーザー指定のシリアライザーまたはパーティショナーのメタデータ ​unavailable.Blocking​ がこのタイムアウトに対して考慮されない場合にブロックされる可能性があります。

60

Maximum block time unit (最大ブロック時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Maximum block time (最大ブロック時間)]​ 項目の時間単位。

SECONDS

Maximum in flight requests (最大インフライト要求)

Number (数値)

ブロックされる前に 1 つの接続でクライアントが送信する肯定応答されていない要求最大数。値が ​1​ より大きく、失敗した送信があると、再試行 (有効になっている場合) によってメッセージが並び替えられる可能性があります。

5

Maximum request size (最大要求サイズ)

Number (数値)

要求の最大サイズ (バイト)。この設定により、プロデューサーが 1 つの要求で送信するレコードバッチ数が制限され、大きな要求が送信されなくなります。また、これは実質的に最大レコードバッチサイズの上限になります。サーバーのレコードバッチサイズの上限がこれとは異なる場合もあります。

1

Maximum request size unit (最大要求サイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Maximum request size (最大要求サイズ)]​ 項目の測定単位。

MB

Producer Acknowledge Mode (プロデューサー肯定応答モード)

Enumeration (列挙)。次のいずれかになります。

  • None (なし)

  • LEADER_ONLY​

  • ALL (すべて)

プロデューサーで要求が完了したとみなされるためにリーダーが受信する必要のある肯定応答の数。この設定では、送信されるレコードの永続性を制御します。

NONE

Default receive buffer size (デフォルトの受信バッファサイズ)

Number (数値)

データを読み込むときに使用する TCP 受信バッファのサイズ (​SO_RCVBUF​)。値が ​-1​ の場合、OS のデフォルトが使用されます。このパラメーターはソースレベルで上書きできます。

64

Default receive buffer size unit (デフォルトの受信バッファサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default receive buffer size (デフォルトの受信バッファサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

KB

Retries amount (再試行回数)

Number (数値)

0​ より大きな値を設定すると、クライアントは一時的なエラーが発生した可能性があるために送信に失敗したレコードを再送信します。この再試行は、エラーが発生したときにクライアントがレコードを再送信する場合と同じです。​max.in.flight.requests.per.connection​ を ​1​ に設定せずに再試行できるようにすると、レコードの順序が変更される可能性があります。これは、2 つのバッチが 1 つのパーティションに送信された場合、最初のバッチが失敗して再試行され、2 番目のバッチが成功すると、2 番目のバッチのレコードが最初に表示される可能性があるためです。また、肯定応答に成功する前に ​delivery.timeout.ms​ で設定されたタイムアウトの期限が切れると、プロデューサーの要求は再試行回数に達する前に失敗します。ユーザーはこれを未設定のままにして、代わりに ​delivery.timeout.ms​ を使用して再試行の動作を制御することをお勧めします。

1

Retry Backoff Timeout (再試行バックオフタイムアウト)

Number (数値)

特定のトピックパーティションに対して失敗した要求を再試行するまでの待機時間。これにより、一部の失敗シナリオの緊密なループで繰り返し要求が送信されることを回避できます。

100

Retry Backoff Timeout Time Unit (再試行バックオフタイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Retry Backoff Timeout (再試行バックオフタイムアウト)]​ 項目の時間単位。

MILLISECONDS

Default send buffer size (デフォルトの送信バッファサイズ)

Number (数値)

データを送信するときに使用する TCP 送信バッファ (​SO_SNDBUF​) のサイズ。値が ​-1​ の場合、OS のデフォルトが使用されます。このパラメーターはソースレベルで上書きできます。

128

Default send buffer size unit (デフォルトの送信バッファサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default send buffer size (デフォルトの送信バッファサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

KB

Default request timeout (デフォルトの要求タイムアウト)

Number (数値)

クライアントが要求の応答を待機する最大時間。タイムアウトが経過する前に応答を受信できない場合、クライアントは必要に応じて要求を再送信します。再試行回数に達すると要求は失敗します。この値は、プロデューサーの不要な再試行によるメッセージの重複の可能性を下げるために ​replica.lag.time.max.ms​ (ブローカー設定) よりも長くする必要があります。

30

Default request timeout time unit (デフォルトの要求タイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Default request timeout (デフォルトの要求タイムアウト)]​ 項目の時間単位。

SECONDS

Partitioner (パーティショナー)

Enumeration (列挙)。次のいずれかになります。

  • DEFAULT

  • ROUND_ROBIN​

  • UNIFORM_STICKY

パーティション分割戦略を制御します。

DEFAULT

TLS Configuration (TLS 設定)

TLS

Mule アプリケーションの通信を保護するためにクライアント側とサーバー側の両方で、使用される TLS 設定を定義します。コネクタは、通信で使用する ​security.protocol​ を自動的に設定します。有効な値は ​PLAINTEXT​、​SSL​、​SASL_PLAINTEXT​、​SASL_SSL​ です。ブローカーで ​SSL​ がプロトコルとして設定されている場合、設定の ​tls:context​ 子要素でキーストアを設定します。また、コネクタは ​security.protocol​ として ​SSL​ (SASL 認証の場合は ​SASL_SSL​) を自動的に使用します。

Endpoint identification algorithm (エンドポイント識別アルゴリズム)

String (文字列)

クライアントがサーバーのホスト名を検証するために使用するエンドポイント識別アルゴリズム。デフォルト値は空の文字列です。つまり、エンドポイント識別アルゴリズムは無効になっています。クライアント (ブローカーによって作成されたブローカー間の通信のクライアント接続を含む) は、ブローカーのホスト名がブローカーの証明書のホスト名と一致していることを確認します。

Principal (プリンシパル)

String (文字列)

コンピューターシステムまたはネットワークで認証されるエンティティ。プリンシパルは、個人、コンピューター、サービス、計算エンティティ (プロセッサーやスレッドなど) になります。

x

Service name (サービス名)

String (文字列)

Kafka が実行時に使用する Kerberos プリンシパル名。

x

Kerberos 設定ファイル (krb5.conf)

String (文字列)

Kerberos 設定情報が格納されている ​krb5.conf​ ファイルへのパス。この情報には、KDC の場所、目的の Kerberos レルムの管理サーバー、現在のレルムのデフォルト、Kerberos アプリケーションのデフォルト、Kerberos レルムのホスト名のマッピングが含まれます。

Use ticket cache (チケットキャッシュを使用)

Boolean (ブール)

チケットキャッシュからチケット保証チケット (TGT) を取得する場合は、このオプションを ​true​ に設定します。チケットキャッシュを使用しない場合は、このオプションを ​false​ に設定します。コネクタは、次のようにチケットキャッシュを検索します。

  • Solaris および Linux の場合、コネクタは ​/tmp/krb5cc_uid​ を検索します。​uid​ は数値のユーザー識別子です。

  • /tmp/krb5cc_uid​ でチケットキャッシュが使用できない場合や、アプリケーションが Windows プラットフォーム上にある場合、コネクタは ​{user.home}{file.separator}krb5cc_{user.name}​ を検索します。 チケットキャッシュの場所は、​[Ticket cache (チケットキャッシュ)]​ 項目の値を設定して上書きできます。

    Windows 環境では、ファイルチケットキャッシュからチケットを取得できない場合、ローカルセキュリティ機関 (LSA) API を使用してチケット保証チケット (TGT) を取得します。

false

Ticket cache (チケットキャッシュ)

String (文字列)

ユーザーのチケット保証チケット (TGT) が含まれるチケットキャッシュの名前。この値を設定する場合は、​[Use ticket cache (チケットキャッシュを使用)]​ も ​true​ に設定する必要があります。設定しない場合、設定エラーが返されます。

Use keytab (キータブを使用)

Boolean (ブール)

コネクタでキータブからプリンシパルのキーを取得する場合は、このオプションを ​true​ に設定します。この値を設定しない場合、コネクタは Kerberos 設定ファイルを使用してキータブを探します。Kerberos 設定ファイルでキータブが指定されていない場合、コネクタは ​{user.home}{file.separator}krb5.keytab​ ファイルを探します。

false

Keytab (キータブ)

String (文字列)

このオプションには、プリンシパルの秘密鍵を取得するキータブのファイル名を設定します。

Store key (キーを保存)

Boolean (ブール)

プリンシパルのサブジェクトの非公開ログイン情報を保存するには、このオプションを ​true​ に設定します。

false

Reconnection (再接続)

Reconnection (再接続)

コネクタ操作で外部サーバーへの接続に失敗した場合に使用する再接続戦略を設定します。
### [](#producer-sasl-scram)Producer SASL/SCRAM (プロデューサー SASL/SCRAM) 接続種別 Salted Challenge Response Authentication Mechanism (SCRAM) または SASL/SCRAM を使用します。これは、PLAIN のようなユーザー名とパスワード認証を実行する従来のメカニズムを使用してセキュリティ上の懸念に対処する SASL メカニズムのファミリーです。Apache Kafka では SCRAM-SHA-256 および SCRAM-SHA-512 がサポートされています。
名前 型 説明 デフォルト値 必須

Bootstrap Server URLs (ブートストラップサーバー URL)

Array of String (文字列の配列)

Kafka クラスターとの接続をブートストラップするサーバーのリスト。これは、使用可能なサーバーの部分的なリストになる場合があります。

x

Batch size (バッチサイズ)

Number (数値)

複数のレコードが同じパーティションに送信される場合、プロデューサーはレコードをまとめて要求を少なくしようとします。これは、クライアントとサーバーの両方のパフォーマンスに寄与します。この設定では、デフォルトのバッチサイズをバイト単位で制御します。このサイズより大きなレコードはまとめられません。ブローカーに送信される要求には、送信可能なデータが含まれる複数のバッチがあり、1 つのバッチは各パーティションに対応します。バッチサイズが小さいと、一括処理の頻度が少なくなり、スループットが低下する可能性があります。バッチサイズが ​0​ の場合、一括処理は完全に無効になります。レコードが追加されることを想定して指定のバッチサイズのバッファが常に割り当てられるため、バッチサイズが非常に大きいと、無駄に使用されるメモリが増加する可能性があります。

16

The batch size unit of measure (バッチサイズの測定単位)。

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Batch size (バッチサイズ)]​ 項目の測定単位。

KB

Buffer size (バッファサイズ)

Number (数値)

サーバーへの送信を待機しているレコードをバッファするためにプロデューサーが使用するメモリの合計バイト。レコードがサーバーに配信される前に送信されると、プロデューサーは ​max.block.ms​ の間ブロックされ、この期間が経過すると例外がスローされます。通常、この設定はプロデューサーが使用する合計メモリに対応しますが、プロデューサーが使用するメモリはバッファに使用されないこともあるため、この設定は正確ではありません。一部の追加メモリは、圧縮 (有効になっている場合) やインフライト要求の管理に使用されます。Apache Kafka ドキュメントのデフォルト値は ​33554432​ (32MB) ですが、CloudHub (v0.1 コア) の Mule インスタンスの想定値に合わせてこれに上限を設定する必要があります。

1

The buffer memory size unit of measure (バッファメモリサイズの測定単位)。

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Buffer size (バッファサイズ)]​ 項目の測定単位。

KB

DNS Lookups (DNS ルックアップ)

Enumeration (列挙)。次のいずれかになります。

  • DEFAULT

  • USE_ALL_DNS_IPS​

  • RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY

クライアントによる DNS ルックアップの使用方法を制御します。

  • USE_ALL_DNS_IPS​

    ルックアップでホスト名の複数の IP アドレスが返されると、接続に失敗するまですべての IP アドレスへの接続が試行されます。ブートストラップサーバーとアドバタイズサーバーの両方に適用されます。

  • RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY​

    各エントリが解決されて、正規名のリストに展開されます。

USE_ALL_DNS_IPS

Compression type (圧縮種別)

Enumeration (列挙)。次のいずれかになります。

  • None (なし)

  • GZIP

  • SNAPPY

  • LZ4

  • ZSTD

プロデューサーによって生成されるすべてのデータの圧縮種別。デフォルトは ​NONE​ (圧縮なし) です。圧縮は、データのバッチ全体に対して実行されるため、一括処理の効率性も圧縮率に影響します。一括処理の量が多いほど、圧縮率が高くなります。

NONE

Connections maximum idle time (最大接続アイドル時間)

Number (数値)

指定された時間に達すると、アイドル接続が終了します。

540

Connections maximum idle time unit (最大接続アイドル時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Connections maximum idle time (接続の最大アイドル時間)]​ 項目の時間単位。

SECONDS

Delivery Timeout (配信タイムアウト)

Number (数値)

send()​ へのコールが返されてから成功または失敗をレポートするまでの時間の上限。これにより、レコードの送信前の合計遅延時間、ブローカーからの肯定応答を待機する時間 (必要な場合)、失敗した送信を再試行できる時間が制限されます。回復不能なエラーが発生した場合、再試行回数に達した場合、以前の配信期限に達したバッチにレコードが追加された場合、プロデューサーは、この設定以内にレコードを送信できなかったことをレポートする可能性があります。この設定の値は、​request.timeout.ms​ と ​linger.ms​ の合計以上にする必要があります。

120

Delivery Timeout Time Unit (配信タイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Delivery Timeout (配信タイムアウト)]​ 項目の時間単位。

SECONDS

Enable idempotence (冪等性を有効化)

Boolean (ブール)

true​ に設定すると、プロデューサーはメッセージごとに 1 つのコピーストリームに書き込まれるようにします。​false​ の場合、プロデューサーはブローカーの失敗により再試行するため、再試行されたメッセージが重複してストリームに書き込まれる可能性があります。冪等性を有効にする場合、​max.in.flight.requests.per.connection​ を ​5​ 以下、再試行回数を ​0​ より大きく、肯定応答を ​all​ にする必要があります。ユーザーがこれらの値を明示的に設定しない場合、適切な値が選択されます。互換性のない値が設定されると、​ConnectionException​ がスローされます。

false

Linger time (延長時間)

Number (数値)

プロデューサーは、要求トランスミッション間に到着するレコードを 1 つのバッチ要求にグループ化します。通常、これは負荷時 (レコードが送信される前に到着する場合) にのみ発生します。ただし、クライアントはそれほど負荷がかかっていなくても要求の数を削減したい場合があります。

この設定では、人為的にわずかに遅延させることでこれを実現します。プロデューサーは、送信をまとめることができるようにレコードをすぐに送信せずに指定された遅延が経過するまで待機し、他のレコードの送信を許可します。これは TCP の Nagle アルゴリズムに似ています。この設定により、一括処理の遅延に上限が設定されます。

パーティションで指定された ​batch.size​ 分のレコードを受信すると、この設定に関係なくすぐに送信されます。ただし、このパーティションで指定された蓄積バイト数よりも受信バイト数が少ないと、プロデューサーは指定された時間だけ「延長」して、他のレコードが到着するまで待機します。

この設定のデフォルトは ​0​ (遅延なし) です。たとえば、​linger.ms=5​ を設定すると、送信される要求数は減りますが、負荷がないときに送信されたレコードにも 5ms のレイテンシーが追加されます。

0

Linger Time Unit (延長時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Linger time (延長時間)]​ 項目の時間単位。

SECONDS

Maximum block time (最大ブロック時間)

Number (数値)

KafkaProducer.send()​ および ​KafkaProducer.partitionsFor()​ をブロックする時間を制御します。これらのメソッドは、バッファがフルの場合や、ユーザー指定のシリアライザーまたはパーティショナーのメタデータ ​unavailable.Blocking​ がこのタイムアウトに対して考慮されない場合にブロックされる可能性があります。

60

Maximum block time unit (最大ブロック時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Maximum block time (最大ブロック時間)]​ 項目の時間単位。

SECONDS

Maximum in flight requests (最大インフライト要求)

Number (数値)

ブロックされる前に 1 つの接続でクライアントが送信する肯定応答されていない要求最大数。値が ​1​ より大きく、失敗した送信があると、再試行 (有効になっている場合) によってメッセージが並び替えられる可能性があります。

5

Maximum request size (最大要求サイズ)

Number (数値)

要求の最大サイズ (バイト)。この設定により、プロデューサーが 1 つの要求で送信するレコードバッチ数が制限され、大きな要求が送信されなくなります。また、これは実質的に最大レコードバッチサイズの上限になります。サーバーのレコードバッチサイズの上限がこれとは異なる場合もあります。

1

Maximum request size unit (最大要求サイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Maximum request size (最大要求サイズ)]​ 項目の測定単位。

MB

Producer Acknowledge Mode (プロデューサー肯定応答モード)

Enumeration (列挙)。次のいずれかになります。

  • None (なし)

  • LEADER_ONLY​

  • ALL (すべて)

プロデューサーで要求が完了したとみなされるためにリーダーが受信する必要のある肯定応答の数。この設定では、送信されるレコードの永続性を制御します。

NONE

Default receive buffer size (デフォルトの受信バッファサイズ)

Number (数値)

データを読み込むときに使用する TCP 受信バッファのサイズ (​SO_RCVBUF​)。値が ​-1​ の場合、OS のデフォルトが使用されます。このパラメーターはソースレベルで上書きできます。

64

Default receive buffer size unit (デフォルトの受信バッファサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default receive buffer size (デフォルトの受信バッファサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

KB

Retries amount (再試行回数)

Number (数値)

0​ より大きな値を設定すると、クライアントは一時的なエラーが発生した可能性があるために送信に失敗したレコードを再送信します。この再試行は、エラーが発生したときにクライアントがレコードを再送信する場合と同じです。​max.in.flight.requests.per.connection​ を ​1​ に設定せずに再試行できるようにすると、レコードの順序が変更される可能性があります。これは、2 つのバッチが 1 つのパーティションに送信された場合、最初のバッチが失敗して再試行され、2 番目のバッチが成功すると、2 番目のバッチのレコードが最初に表示される可能性があるためです。また、肯定応答に成功する前に ​delivery.timeout.ms​ で設定されたタイムアウトの期限が切れると、プロデューサーの要求は再試行回数に達する前に失敗します。ユーザーはこれを未設定のままにして、代わりに ​delivery.timeout.ms​ を使用して再試行の動作を制御することをお勧めします。

1

Retry Backoff Timeout (再試行バックオフタイムアウト)

Number (数値)

特定のトピックパーティションに対して失敗した要求を再試行するまでの待機時間。これにより、一部の失敗シナリオの緊密なループで繰り返し要求が送信されることを回避できます。

100

Retry Backoff Timeout Time Unit (再試行バックオフタイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Retry Backoff Timeout (再試行バックオフタイムアウト)]​ 項目の時間単位。

MILLISECONDS

Default send buffer size (デフォルトの送信バッファサイズ)

Number (数値)

データを送信するときに使用する TCP 送信バッファ (​SO_SNDBUF​) のサイズ。値が ​-1​ の場合、OS のデフォルトが使用されます。このパラメーターはソースレベルで上書きできます。

128

Default send buffer size unit (デフォルトの送信バッファサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default send buffer size (デフォルトの送信バッファサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

KB

Default request timeout (デフォルトの要求タイムアウト)

Number (数値)

クライアントが要求の応答を待機する最大時間。タイムアウトが経過する前に応答を受信できない場合、クライアントは必要に応じて要求を再送信します。再試行回数に達すると要求は失敗します。この値は、プロデューサーの不要な再試行によるメッセージの重複の可能性を下げるために ​replica.lag.time.max.ms​ (ブローカー設定) よりも長くする必要があります。

30

Default request timeout time unit (デフォルトの要求タイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Default request timeout (デフォルトの要求タイムアウト)]​ 項目の時間単位。

SECONDS

Partitioner (パーティショナー)

Enumeration (列挙)。次のいずれかになります。

  • DEFAULT

  • ROUND_ROBIN​

  • UNIFORM_STICKY

パーティション分割戦略を制御します。

DEFAULT

TLS Configuration (TLS 設定)

TLS

Mule アプリケーションの通信を保護するためにクライアント側とサーバー側の両方で、使用される TLS 設定を定義します。コネクタは、通信で使用する ​security.protocol​ を自動的に設定します。有効な値は ​PLAINTEXT​、​SSL​、​SASL_PLAINTEXT​、​SASL_SSL​ です。ブローカーで ​SSL​ がプロトコルとして設定されている場合、設定の ​tls:context​ 子要素でキーストアを設定します。また、コネクタは ​security.protocol​ として ​SSL​ (SASL 認証の場合は ​SASL_SSL​) を自動的に使用します。

Endpoint identification algorithm (エンドポイント識別アルゴリズム)

String (文字列)

クライアントがサーバーのホスト名を検証するために使用するエンドポイント識別アルゴリズム。デフォルト値は空の文字列です。つまり、エンドポイント識別アルゴリズムは無効になっています。クライアント (ブローカーによって作成されたブローカー間の通信のクライアント接続を含む) は、ブローカーのホスト名がブローカーの証明書のホスト名と一致していることを確認します。

Username (ユーザー名)

String (文字列)

ログインで使用するユーザー名。

x

Password (パスワード)

String (文字列)

ログインで使用するパスワード。

x

EncryptionType

Enumeration (列挙)。次のいずれかになります。

  • SHA256

  • SHA512

SCRAM で使用される暗号化アルゴリズム。

x

Reconnection (再接続)

Reconnection (再接続)

コネクタ操作で外部サーバーへの接続に失敗した場合に使用する再接続戦略を設定します。
### [](#producer-sasl-plain)Producer SASL/PLAIN (プロデューサー SASL/PLAIN) 接続種別 ユーザー名とパスワードで認証する SASL を使用します。
名前 型 説明 デフォルト値 必須

Bootstrap Server URLs (ブートストラップサーバー URL)

Array of String (文字列の配列)

Kafka クラスターとの接続をブートストラップするサーバーのリスト。これは、使用可能なサーバーの部分的なリストになる場合があります。

x

Batch size (バッチサイズ)

Number (数値)

複数のレコードが同じパーティションに送信される場合、プロデューサーはレコードをまとめて要求を少なくしようとします。これは、クライアントとサーバーの両方のパフォーマンスに寄与します。この設定では、デフォルトのバッチサイズをバイト単位で制御します。このサイズより大きなレコードはまとめられません。ブローカーに送信される要求には、送信可能なデータが含まれる複数のバッチがあり、1 つのバッチは各パーティションに対応します。バッチサイズが小さいと、一括処理の頻度が高くなり、スループットが低下する可能性があります。バッチサイズが 0 の場合、一括処理は完全に無効になります。レコードが追加されることを想定して指定のバッチサイズのバッファが常に割り当てられるため、バッチサイズが非常に大きいと、無駄に使用されるメモリが増加する可能性があります。

16

The batch size unit of measure (バッチサイズの測定単位)。

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Batch size (バッチサイズ)]​ 項目の測定単位。

KB

Buffer size (バッファサイズ)

Number (数値)

サーバーへの送信を待機しているレコードをバッファするためにプロデューサーが使用するメモリの合計バイト。レコードがサーバーに配信される前に送信されると、プロデューサーは ​max.block.ms​ の間ブロックされ、この期間が経過すると例外がスローされます。通常、この設定はプロデューサーが使用する合計メモリに対応しますが、プロデューサーが使用するメモリはバッファに使用されないこともあるため、この設定は正確ではありません。一部の追加メモリは、圧縮 (有効になっている場合) やインフライト要求の管理に使用されます。Apache Kafka ドキュメントのデフォルト値は ​33554432​ (32MB) ですが、CloudHub (v0.1 コア) の Mule インスタンスの想定値に合わせてこれに上限を設定する必要があります。

1

The buffer memory size unit of measure (バッファメモリサイズの測定単位)。

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Buffer size (バッファサイズ)]​ 項目の測定単位。

KB

DNS Lookups (DNS ルックアップ)

Enumeration (列挙)。次のいずれかになります。

  • DEFAULT

  • USE_ALL_DNS_IPS​

  • RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY

クライアントによる DNS ルックアップの使用方法を制御します。

  • USE_ALL_DNS_IPS​

    ルックアップでホスト名の複数の IP アドレスが返されると、接続に失敗するまですべての IP アドレスへの接続が試行されます。ブートストラップサーバーとアドバタイズサーバーの両方に適用されます。

  • RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY​

    各エントリが解決されて、正規名のリストに展開されます。

USE_ALL_DNS_IPS

Compression type (圧縮種別)

Enumeration (列挙)。次のいずれかになります。

  • None (なし)

  • GZIP

  • SNAPPY

  • LZ4

  • ZSTD

プロデューサーによって生成されるすべてのデータの圧縮種別。デフォルトは ​NONE​ (圧縮なし) です。圧縮は、データのバッチ全体に対して実行されるため、一括処理の効率性も圧縮率に影響します。一括処理の量が多いほど、圧縮率が高くなります。

NONE

Connections maximum idle time (最大接続アイドル時間)

Number (数値)

指定された時間に達すると、アイドル接続が終了します。

540

Connections maximum idle time unit (最大接続アイドル時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Connections maximum idle time (接続の最大アイドル時間)]​ 項目の時間単位。

SECONDS

Delivery Timeout (配信タイムアウト)

Number (数値)

send()​ へのコールが返されてから成功または失敗をレポートするまでの時間の上限。これにより、レコードの送信前の合計遅延時間、ブローカーからの肯定応答を待機する時間 (必要な場合)、失敗した送信を再試行できる時間が制限されます。回復不能なエラーが発生した場合、再試行回数に達した場合、以前の配信期限に達したバッチにレコードが追加された場合、プロデューサーは、この設定以内にレコードを送信できなかったことをレポートする可能性があります。この設定の値は、​request.timeout.ms​ と ​linger.ms​ の合計以上にする必要があります。

120

Delivery Timeout Time Unit (配信タイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Delivery Timeout (配信タイムアウト)]​ 項目の時間単位。

SECONDS

Enable idempotence (冪等性を有効化)

Boolean (ブール)

true​ に設定すると、プロデューサーはメッセージごとに 1 つのコピーストリームに書き込まれるようにします。​false​ の場合、プロデューサーはブローカーの失敗により再試行するため、再試行されたメッセージが重複してストリームに書き込まれる可能性があります。冪等性を有効にする場合、​max.in.flight.requests.per.connection​ を ​5​ 以下、再試行回数を ​0​ より大きく、肯定応答を ​all​ にする必要があります。ユーザーがこれらの値を明示的に設定しない場合、適切な値が選択されます。互換性のない値が設定されると、​ConnectionException​ がスローされます。

false

Linger time (延長時間)

Number (数値)

プロデューサーは、要求トランスミッション間に到着するレコードを 1 つのバッチ要求にグループ化します。通常、これは負荷時 (レコードが送信される前に到着する場合) にのみ発生します。ただし、クライアントはそれほど負荷がかかっていなくても要求の数を削減したい場合があります。

この設定では、人為的にわずかに遅延させることでこれを実現します。プロデューサーは、送信をまとめることができるようにレコードをすぐに送信せずに指定された遅延が経過するまで待機し、他のレコードの送信を許可します。これは TCP の Nagle アルゴリズムに似ています。この設定により、一括処理の遅延に上限が設定されます。

パーティションで指定された ​batch.size​ 分のレコードを受信すると、この設定に関係なくすぐに送信されます。ただし、このパーティションで指定された蓄積バイト数よりも受信バイト数が少ないと、プロデューサーは指定された時間だけ「延長」して、他のレコードが到着するまで待機します。

この設定のデフォルトは ​0​ (遅延なし) です。たとえば、​linger.ms=5​ を設定すると、送信される要求数は減りますが、負荷がないときに送信されたレコードにも 5ms のレイテンシーが追加されます。

0

Linger Time Unit (延長時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Linger time (延長時間)]​ 項目の時間単位。

SECONDS

Maximum block time (最大ブロック時間)

Number (数値)

KafkaProducer.send()​ および ​KafkaProducer.partitionsFor()​ をブロックする時間を制御します。これらのメソッドは、バッファがフルの場合や、ユーザー指定のシリアライザーまたはパーティショナーのメタデータ ​unavailable.Blocking​ がこのタイムアウトに対して考慮されない場合にブロックされる可能性があります。

60

Maximum block time unit (最大ブロック時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Maximum block time (最大ブロック時間)]​ 項目の時間単位。

SECONDS

Maximum in flight requests (最大インフライト要求)

Number (数値)

ブロックされる前に 1 つの接続でクライアントが送信する肯定応答されていない要求最大数。値が ​1​ より大きく、失敗した送信があると、再試行 (有効になっている場合) によってメッセージが並び替えられる可能性があります。

5

Maximum request size (最大要求サイズ)

Number (数値)

要求の最大サイズ (バイト)。この設定により、プロデューサーが 1 つの要求で送信するレコードバッチ数が制限され、大きな要求が送信されなくなります。また、これは実質的に最大レコードバッチサイズの上限になります。サーバーのレコードバッチサイズの上限がこれとは異なる場合もあります。

1

Maximum request size unit (最大要求サイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Maximum request size (最大要求サイズ)]​ 項目の測定単位。

MB

Producer Acknowledge Mode (プロデューサー肯定応答モード)

Enumeration (列挙)。次のいずれかになります。

  • None (なし)

  • LEADER_ONLY​

  • ALL (すべて)

プロデューサーで要求が完了したとみなされるためにリーダーが受信する必要のある肯定応答の数。この設定では、送信されるレコードの永続性を制御します。

NONE

Default receive buffer size (デフォルトの受信バッファサイズ)

Number (数値)

データを読み込むときに使用する TCP 受信バッファのサイズ (​SO_RCVBUF​)。値が ​-1​ の場合、OS のデフォルトが使用されます。このパラメーターはソースレベルで上書きできます。

64

Default receive buffer size unit (デフォルトの受信バッファサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default receive buffer size (デフォルトの受信バッファサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

KB

Retries amount (再試行回数)

Number (数値)

0​ より大きな値を設定すると、クライアントは一時的なエラーが発生した可能性があるために送信に失敗したレコードを再送信します。この再試行は、エラーが発生したときにクライアントがレコードを再送信する場合と同じです。​max.in.flight.requests.per.connection​ を ​1​ に設定せずに再試行できるようにすると、レコードの順序が変更される可能性があります。これは、2 つのバッチが 1 つのパーティションに送信された場合、最初のバッチが失敗して再試行され、2 番目のバッチが成功すると、2 番目のバッチのレコードが最初に表示される可能性があるためです。また、肯定応答に成功する前に ​delivery.timeout.ms​ で設定されたタイムアウトの期限が切れると、プロデューサーの要求は再試行回数に達する前に失敗します。ユーザーはこれを未設定のままにして、代わりに ​delivery.timeout.ms​ を使用して再試行の動作を制御することをお勧めします。

1

Retry Backoff Timeout (再試行バックオフタイムアウト)

Number (数値)

特定のトピックパーティションに対して失敗した要求を再試行するまでの待機時間。これにより、一部の失敗シナリオの緊密なループで繰り返し要求が送信されることを回避できます。

100

Retry Backoff Timeout Time Unit (再試行バックオフタイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Retry Backoff Timeout (再試行バックオフタイムアウト)]​ 項目の時間単位。

MILLISECONDS

Default send buffer size (デフォルトの送信バッファサイズ)

Number (数値)

データを送信するときに使用する TCP 送信バッファ (​SO_SNDBUF​) のサイズ。値が ​-1​ の場合、OS のデフォルトが使用されます。このパラメーターはソースレベルで上書きできます。

128

Default send buffer size unit (デフォルトの送信バッファサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default send buffer size (デフォルトの送信バッファサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

KB

Default request timeout (デフォルトの要求タイムアウト)

Number (数値)

クライアントが要求の応答を待機する最大時間。タイムアウトが経過する前に応答を受信できない場合、クライアントは必要に応じて要求を再送信します。再試行回数に達すると要求は失敗します。この値は、プロデューサーの不要な再試行によるメッセージの重複の可能性を下げるために ​replica.lag.time.max.ms​ (ブローカー設定) よりも長くする必要があります。

30

Default request timeout time unit (デフォルトの要求タイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Default request timeout (デフォルトの要求タイムアウト)]​ 項目の時間単位。

SECONDS

Partitioner (パーティショナー)

Enumeration (列挙)。次のいずれかになります。

  • DEFAULT

  • ROUND_ROBIN​

  • UNIFORM_STICKY

パーティション分割戦略を制御します。

DEFAULT

TLS Configuration (TLS 設定)

TLS

Mule アプリケーションの通信を保護するためにクライアント側とサーバー側の両方で、使用される TLS 設定を定義します。コネクタは、通信で使用する ​security.protocol​ を自動的に設定します。有効な値は ​PLAINTEXT​、​SSL​、​SASL_PLAINTEXT​、​SASL_SSL​ です。ブローカーで ​SSL​ がプロトコルとして設定されている場合、設定の ​tls:context​ 子要素でキーストアを設定します。また、コネクタは ​security.protocol​ として ​SSL​ (SASL 認証の場合は ​SASL_SSL​) を自動的に使用します。

Endpoint identification algorithm (エンドポイント識別アルゴリズム)

String (文字列)

クライアントがサーバーのホスト名を検証するために使用するエンドポイント識別アルゴリズム。デフォルト値は空の文字列です。つまり、エンドポイント識別アルゴリズムは無効になっています。クライアント (ブローカーによって作成されたブローカー間の通信のクライアント接続を含む) は、ブローカーのホスト名がブローカーの証明書のホスト名と一致していることを確認します。

Username (ユーザー名)

String (文字列)

ログインで使用するユーザー名。

x

Password (パスワード)

String (文字列)

ログインで使用するパスワード。

x

Reconnection (再接続)

Reconnection (再接続)

コネクタ操作で外部サーバーへの接続に失敗した場合に使用する再接続戦略を設定します。
### [](#producer-config_producer-sasl-token-connection)Producer SASL/TOKEN (プロデューサー SASL/TOKEN) 接続種別 委任トークンを使用して Kafka クラスターに認証します。
セキュリティ上の理由により、最初の認証で委任トークンが使用されている場合、委任トークンは更新できません。詳細は、 「Delegation Token Support for Kafka (Kafka の委任トークンサポート)」​を参照してください。
名前 型 説明 デフォルト値 必須

Bootstrap Server URLs (ブートストラップサーバー URL)

Array of String (文字列の配列)

Kafka クラスターとの接続をブートストラップするサーバーのリスト。これは、使用可能なサーバーの部分的なリストになる場合があります。

x

Batch size (バッチサイズ)

Number (数値)

複数のレコードが同じパーティションに送信される場合、プロデューサーはレコードをまとめて要求を少なくしようとします。これは、クライアントとサーバーの両方のパフォーマンスに寄与します。この設定では、デフォルトのバッチサイズをバイト単位で制御します。このサイズより大きなレコードはまとめられません。ブローカーに送信される要求には、送信可能なデータが含まれる複数のバッチがあり、1 つのバッチは各パーティションに対応します。バッチサイズが小さいと、一括処理の頻度が高くなり、スループットが低下する可能性があります。バッチサイズが 0 の場合、一括処理は完全に無効になります。レコードが追加されることを想定して指定のバッチサイズのバッファが常に割り当てられるため、バッチサイズが非常に大きいと、無駄に使用されるメモリが増加する可能性があります。

16

The batch size unit of measure (バッチサイズの測定単位)。

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Batch size (バッチサイズ)]​ 項目の測定単位。

KB

Buffer size (バッファサイズ)

Number (数値)

サーバーへの送信を待機しているレコードをバッファするためにプロデューサーが使用するメモリの合計バイト。レコードがサーバーに配信される前に送信されると、プロデューサーは ​max.block.ms​ の間ブロックされ、この期間が経過すると例外がスローされます。通常、この設定はプロデューサーが使用する合計メモリに対応しますが、プロデューサーが使用するメモリはバッファに使用されないこともあるため、この設定は正確ではありません。一部の追加メモリは、圧縮 (有効になっている場合) やインフライト要求の管理に使用されます。Apache Kafka ドキュメントのデフォルト値は ​33554432​ (32MB) ですが、CloudHub (v0.1 コア) の Mule インスタンスの想定値に合わせてこれに上限を設定する必要があります。

1

The buffer memory size unit of measure (バッファメモリサイズの測定単位)。

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Buffer size (バッファサイズ)]​ 項目の測定単位。

KB

DNS Lookups (DNS ルックアップ)

Enumeration (列挙)。次のいずれかになります。

  • DEFAULT

  • USE_ALL_DNS_IPS​

  • RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY

クライアントによる DNS ルックアップの使用方法を制御します。

  • USE_ALL_DNS_IPS​

    ルックアップでホスト名の複数の IP アドレスが返されると、接続に失敗するまですべての IP アドレスへの接続が試行されます。ブートストラップサーバーとアドバタイズサーバーの両方に適用されます。

  • RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY​

    各エントリが解決されて、正規名のリストに展開されます。

USE_ALL_DNS_IPS

Compression type (圧縮種別)

Enumeration (列挙)。次のいずれかになります。

  • None (なし)

  • GZIP

  • SNAPPY

  • LZ4

  • ZSTD

プロデューサーによって生成されるすべてのデータの圧縮種別。デフォルトは ​NONE​ (圧縮なし) です。圧縮は、データのバッチ全体に対して実行されるため、一括処理の効率性も圧縮率に影響します。一括処理の量が多いほど、圧縮率が高くなります。

NONE

Connections maximum idle time (最大接続アイドル時間)

Number (数値)

指定された時間に達すると、アイドル接続が終了します。

540

Connections maximum idle time unit (最大接続アイドル時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Connections maximum idle time (接続の最大アイドル時間)]​ 項目の時間単位。

SECONDS

Delivery Timeout (配信タイムアウト)

Number (数値)

send()​ へのコールが返されてから成功または失敗をレポートするまでの時間の上限。これにより、レコードの送信前の合計遅延時間、ブローカーからの肯定応答を待機する時間 (必要な場合)、失敗した送信を再試行できる時間が制限されます。回復不能なエラーが発生した場合、再試行回数に達した場合、以前の配信期限に達したバッチにレコードが追加された場合、プロデューサーは、この設定以内にレコードを送信できなかったことをレポートする可能性があります。この設定の値は、​request.timeout.ms​ と ​linger.ms​ の合計以上にする必要があります。

120

Delivery Timeout Time Unit (配信タイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Delivery Timeout (配信タイムアウト)]​ 項目の時間単位。

SECONDS

Enable idempotence (冪等性を有効化)

Boolean (ブール)

true​ に設定すると、プロデューサーはメッセージごとに 1 つのコピーストリームに書き込まれるようにします。​false​ の場合、プロデューサーはブローカーの失敗により再試行するため、再試行されたメッセージが重複してストリームに書き込まれる可能性があります。冪等性を有効にする場合、​max.in.flight.requests.per.connection​ を ​5​ 以下、再試行回数を ​0​ より大きく、肯定応答を ​all​ にする必要があります。ユーザーがこれらの値を明示的に設定しない場合、適切な値が選択されます。互換性のない値が設定されると、​ConnectionException​ がスローされます。

false

Linger time (延長時間)

Number (数値)

プロデューサーは、要求トランスミッション間に到着するレコードを 1 つのバッチ要求にグループ化します。通常、これは負荷時 (レコードが送信される前に到着する場合) にのみ発生します。ただし、クライアントはそれほど負荷がかかっていなくても要求の数を削減したい場合があります。

この設定では、人為的にわずかに遅延させることでこれを実現します。プロデューサーは、送信をまとめることができるようにレコードをすぐに送信せずに指定された遅延が経過するまで待機し、他のレコードの送信を許可します。これは TCP の Nagle アルゴリズムに似ています。この設定により、一括処理の遅延に上限が設定されます。

パーティションで指定された ​batch.size​ 分のレコードを受信すると、この設定に関係なくすぐに送信されます。ただし、このパーティションで指定された蓄積バイト数よりも受信バイト数が少ないと、プロデューサーは指定された時間だけ「延長」して、他のレコードが到着するまで待機します。

この設定のデフォルトは ​0​ (遅延なし) です。たとえば、​linger.ms=5​ を設定すると、送信される要求数は減りますが、負荷がないときに送信されたレコードにも 5ms のレイテンシーが追加されます。

0

Linger Time Unit (延長時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Linger time (延長時間)]​ 項目の時間単位。

SECONDS

Maximum block time (最大ブロック時間)

Number (数値)

KafkaProducer.send()​ および ​KafkaProducer.partitionsFor()​ をブロックする時間を制御します。これらのメソッドは、バッファがフルの場合や、ユーザー指定のシリアライザーまたはパーティショナーのメタデータ ​unavailable.Blocking​ がこのタイムアウトに対して考慮されない場合にブロックされる可能性があります。

60

Maximum block time unit (最大ブロック時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Maximum block time (最大ブロック時間)]​ 項目の時間単位。

SECONDS

Maximum in flight requests (最大インフライト要求)

Number (数値)

ブロックされる前に 1 つの接続でクライアントが送信する肯定応答されていない要求最大数。値が ​1​ より大きく、失敗した送信があると、再試行 (有効になっている場合) によってメッセージが並び替えられる可能性があります。

5

Maximum request size (最大要求サイズ)

Number (数値)

要求の最大サイズ (バイト)。この設定により、プロデューサーが 1 つの要求で送信するレコードバッチ数が制限され、大きな要求が送信されなくなります。また、これは実質的に最大レコードバッチサイズの上限になります。サーバーのレコードバッチサイズの上限がこれとは異なる場合もあります。

1

Maximum request size unit (最大要求サイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Maximum request size (最大要求サイズ)]​ 項目の測定単位。

MB

Producer Acknowledge Mode (プロデューサー肯定応答モード)

Enumeration (列挙)。次のいずれかになります。

  • None (なし)

  • LEADER_ONLY​

  • ALL (すべて)

プロデューサーで要求が完了したとみなされるためにリーダーが受信する必要のある肯定応答の数。この設定では、送信されるレコードの永続性を制御します。

NONE

Default receive buffer size (デフォルトの受信バッファサイズ)

Number (数値)

データを読み込むときに使用する TCP 受信バッファのサイズ (​SO_RCVBUF​)。値が ​-1​ の場合、OS のデフォルトが使用されます。このパラメーターはソースレベルで上書きできます。

64

Default receive buffer size unit (デフォルトの受信バッファサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default receive buffer size (デフォルトの受信バッファサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

KB

Retries amount (再試行回数)

Number (数値)

0​ より大きな値を設定すると、クライアントは一時的なエラーが発生した可能性があるために送信に失敗したレコードを再送信します。この再試行は、エラーが発生したときにクライアントがレコードを再送信する場合と同じです。​max.in.flight.requests.per.connection​ を ​1​ に設定せずに再試行できるようにすると、レコードの順序が変更される可能性があります。これは、2 つのバッチが 1 つのパーティションに送信された場合、最初のバッチが失敗して再試行され、2 番目のバッチが成功すると、2 番目のバッチのレコードが最初に表示される可能性があるためです。また、肯定応答に成功する前に ​delivery.timeout.ms​ で設定されたタイムアウトの期限が切れると、プロデューサーの要求は再試行回数に達する前に失敗します。ユーザーはこれを未設定のままにして、代わりに ​delivery.timeout.ms​ を使用して再試行の動作を制御することをお勧めします。

1

Retry Backoff Timeout (再試行バックオフタイムアウト)

Number (数値)

特定のトピックパーティションに対して失敗した要求を再試行するまでの待機時間。これにより、一部の失敗シナリオの緊密なループで繰り返し要求が送信されることを回避できます。

100

Retry Backoff Timeout Time Unit (再試行バックオフタイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Retry Backoff Timeout (再試行バックオフタイムアウト)]​ 項目の時間単位。

MILLISECONDS

Default send buffer size (デフォルトの送信バッファサイズ)

Number (数値)

データを送信するときに使用する TCP 送信バッファ (​SO_SNDBUF​) のサイズ。値が ​-1​ の場合、OS のデフォルトが使用されます。このパラメーターはソースレベルで上書きできます。

128

Default send buffer size unit (デフォルトの送信バッファサイズ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Default send buffer size (デフォルトの送信バッファサイズ)]​ 項目の測定単位。このパラメーターはソースレベルで上書きできます。

KB

Default request timeout (デフォルトの要求タイムアウト)

Number (数値)

クライアントが要求の応答を待機する最大時間。タイムアウトが経過する前に応答を受信できない場合、クライアントは必要に応じて要求を再送信します。再試行回数に達すると要求は失敗します。この値は、プロデューサーの不要な再試行によるメッセージの重複の可能性を下げるために ​replica.lag.time.max.ms​ (ブローカー設定) よりも長くする必要があります。

30

Default request timeout time unit (デフォルトの要求タイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Default request timeout (デフォルトの要求タイムアウト)]​ 項目の時間単位。

SECONDS

Partitioner (パーティショナー)

Enumeration (列挙)。次のいずれかになります。

  • DEFAULT

  • ROUND_ROBIN​

  • UNIFORM_STICKY

パーティション分割戦略を制御します。

DEFAULT

TLS Configuration (TLS 設定)

TLS

Mule アプリケーションの通信を保護するためにクライアント側とサーバー側の両方で、使用される TLS 設定を定義します。コネクタは、通信で使用する ​security.protocol​ を自動的に設定します。有効な値は ​PLAINTEXT​、​SSL​、​SASL_PLAINTEXT​、​SASL_SSL​ です。ブローカーで ​SSL​ がプロトコルとして設定されている場合、設定の ​tls:context​ 子要素でキーストアを設定します。また、コネクタは ​security.protocol​ として ​SSL​ (SASL 認証の場合は ​SASL_SSL​) を自動的に使用します。

Endpoint identification algorithm (エンドポイント識別アルゴリズム)

String (文字列)

クライアントがサーバーのホスト名を検証するために使用するエンドポイント識別アルゴリズム。デフォルト値は空の文字列です。つまり、エンドポイント識別アルゴリズムは無効になっています。クライアント (ブローカーによって作成されたブローカー間の通信のクライアント接続を含む) は、ブローカーのホスト名がブローカーの証明書のホスト名と一致していることを確認します。

Token ID (トークン ID)

String (文字列)

トークンの ID。

x

Token HMAC (トークン HMAC)

String (文字列)

トークン HAMC。

x

Encryption type (暗号化種別)

Enumeration (列挙)。次のいずれかになります。

  • SCRAM_SHA_256​

  • SCRAM_SHA_512

SCRAM で使用される暗号化アルゴリズム。

x

Reconnection (再接続)

Reconnection (再接続)

コネクタ操作で外部サーバーへの接続に失敗した場合に使用する再接続戦略を設定します。
## [](#コンシューマーソース)コンシューマーソース - [Batch Message Listener](#batch-message-listener) - [Message Listener](#message-listener) ### [](#batch-message-listener)Batch Message Listener `` このソースでは、Kafka クラスターからのメッセージのコンシュームがサポートされており、フローへのメッセージのリストが生成されます。
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Poll timeout (ポーリングタイムアウト)

Number (数値)

ブロックする時間。ポーリングの合計タイムアウトを定義します。

Poll timeout time unit (ポーリングタイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Poll timeout (ポーリングタイムアウト)]​ 項目の時間単位。

Acknowledgement mode (肯定応答モード)

Enumeration (列挙)。次のいずれかになります。

  • AUTO

  • MANUAL

  • IMMEDIATE

  • DUPS_OK

Kafka ブローカーインスタンスにメッセージのコンシュームを通知する方法を定義します。

  • AUTO

    フローが正常に完了した場合にメッセージを自動的にコミットします。

  • MANUAL

    ユーザーは ​Commit​ 操作を使用して受信時にメッセージを手動でコミットする必要があります。

  • IMMEDIATE

    Mule は受信時にメッセージを自動的にコミットしてからフローをトリガーします。

  • DUPS_OK​

    [MANUAL] と同様に動作しますが、コミットが非同期のため、レコードが重複する可能性があります。

並列コンシューマーの量。

Number (数値)

Number of parallel consumers (並列コンシューマー数)。

1

Primary Node Only (プライマリノードのみ)

Boolean (ブール)

クラスターでの Mule インスタンスの実行時、このソースをプライマリノード上でのみ実行するかどうかを決定します。

Redelivery Policy (再配信ポリシー)

Redelivery Policy (再配信ポリシー)

同じメッセージの再配信を処理するためのポリシーを定義します。

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
#### [](#出力)出力

型

Record (レコード)​ の配列

Attributes Type (属性型)

Consumer Context (コンシューマーコンテキスト)
#### [](#関連する設定)関連する設定 - [Consumer Configuration (コンシューマー設定)](#consumer-config)
Batch Message Listener​ ソースでは、入力ストリームとしてレコードのバッチを取得するため、設定可能なストリーミング戦略がサポートされません。デフォルトでは、このソースのストリーミング戦略設定は反復不可能ストリームです。
### [](#message-listener)Message Listener `` このソースでは、Kafka クラスターからのメッセージのコンシュームがサポートされており、フローへの 1 つのメッセージが生成されます。
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Poll timeout (ポーリングタイムアウト)

Number (数値)

ブロックする時間。ポーリングの合計タイムアウトを定義します。

Poll timeout time unit (ポーリングタイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Poll timeout (ポーリングタイムアウト)]​ 項目の時間単位。

Acknowledgement mode (肯定応答モード)

Enumeration (列挙)。次のいずれかになります。

  • AUTO

  • MANUAL

  • IMMEDIATE

  • DUPS_OK

Kafka ブローカーインスタンスにメッセージのコンシュームを通知する方法を定義します。

  • AUTO

    フローが正常に完了した場合にメッセージを自動的にコミットします。

  • MANUAL

    ユーザーは ​Commit​ 操作を使用して受信時にメッセージを手動でコミットする必要があります。

  • IMMEDIATE

    Mule は受信時にメッセージを自動的にコミットしてからフローをトリガーします。

  • DUPS_OK​

    [MANUAL] と同様に動作しますが、コミットが非同期のため、レコードが重複する可能性があります。

並列コンシューマーの量。

Number (数値)

Number of parallel consumers (並列コンシューマー数)。

1

Primary Node Only (プライマリノードのみ)

Boolean (ブール)

クラスターでの Mule インスタンスの実行時、このソースをプライマリノード上でのみ実行するかどうかを決定します。

Streaming Strategy (ストリーミング戦略)

Mule によるストリームの処理方法を設定します。反復可能ストリームは、デフォルトの動作です。

Redelivery Policy (再配信ポリシー)

Redelivery Policy (再配信ポリシー)

同じメッセージの再配信を処理するためのポリシーを定義します。

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
#### [](#出力-2)出力

型

Binary (バイナリ)

Attributes Type (属性型)

Kafka Record Attributes (Kafka レコード属性)
#### [](#関連する設定-2)関連する設定 - [Consumer Configuration (コンシューマー設定)](#consumer-config) ## [](#コンシューマー操作)コンシューマー操作 - [Commit](#commit) - [Consume](#consume) - [Seek](#seek) ### [](#commit)Commit `` **Message Listener**​ でコンシュームされるメッセージまたはメッセージのバッチに関連付けられているオフセットをコミットします。これは、​**Batch Message Listener**​ ソースでコンシュームされるメッセージのリストまたは 1 つのメッセージになります。
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Consumer commit key (コンシューマーコミットキー)

String (文字列)

前回のポーリングのコミットキー。この操作は、この値を属性として Mule イベントに挿入するソース (​Batch Message Listener​ または ​Message Listener​) のいずれかを使用しているフロー内で使用される場合のみ有効です。

x

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
#### [](#関連する設定-3)関連する設定 - [Consumer Configuration (コンシューマー設定)](#consumer-config) #### [](#スロー)スロー - KAFKA:INVALID\_ACK\_MODE - KAFKA:RETRY\_EXHAUSTED - KAFKA:ALREADY\_COMMITTED - KAFKA:TIMEOUT - KAFKA:SESSION\_NOT\_FOUND - KAFKA:NOT\_FOUND - KAFKA:CONNECTIVITY ### [](#consume)Consume `` 1 つ以上の Kafka トピックからメッセージを受信します。この操作の機能は ​**Message Listener**​ ソースと似ているため、それに適用されるすべての操作がこの操作にも適用されます。
Consume​ 操作では ​consumerCommitKey​ は返されません。
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Consumption timeout (コンシュームタイムアウト)

Number (数値)

この操作でメッセージの受信を待機する時間単位数。

Timeout time unit (タイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Consumption timeout (コンシュームタイムアウト)]​ 項目の時間単位。

Operation Timeout (操作タイムアウト)

Number (数値)

実行を開始する操作のタイムアウト。

Operation Timeout Time Unit (操作タイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Operation Timeout (操作タイムアウト)]​ 項目の時間単位。

Acknowledgement mode (肯定応答モード)

Enumeration (列挙)。次のいずれかになります。

  • AUTO

  • MANUAL

  • IMMEDIATE

  • DUPS_OK

Kafka ブローカーインスタンスにメッセージのコンシュームを通知する方法を定義します。

  • AUTO

    フローが正常に完了した場合にメッセージを自動的にコミットします。

  • MANUAL

    ユーザーは ​Commit​ 操作を使用して受信時にメッセージを手動でコミットする必要があります。

  • IMMEDIATE

    Mule は受信時にメッセージを自動的にコミットしてからフローをトリガーします。

  • DUPS_OK​

    [MANUAL] と同様に動作しますが、コミットが非同期のため、レコードが重複する可能性があります。

IMMEDIATE

Streaming Strategy (ストリーミング戦略)

Mule によるストリームの処理方法を設定します。反復可能ストリームは、デフォルトの動作です。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は ​[Target Variable (対象変数)]​ 項目に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
#### [](#出力-3)出力

型

Binary (バイナリ)

Attributes Type (属性型)

Kafka Record Attributes (Kafka レコード属性)
#### [](#関連する設定-4)関連する設定 - [Consumer Configuration (コンシューマー設定)](#consumer-config) #### [](#スロー-2)スロー - KAFKA:RETRY\_EXHAUSTED - KAFKA:ILLEGAL\_STATE - KAFKA:TIMEOUT - KAFKA:INVALID\_OFFSET - KAFKA:INVALID\_INPUT - KAFKA:NOT\_FOUND - KAFKA:CONNECTIVITY ### [](#seek)Seek `` 特定のトピックおよびパーティションのコンシューマーの現在のオフセットを指定のオフセット値に設定します。
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Topic (トピック)

String (文字列)

Seek​ 操作が実行されるトピックの名前。

x

Partition (パーティション)

Number (数値)

オフセットが変更されるパーティション番号。

x

オフセット

Number (数値)

設定済みパーティションに対してコミットするオフセット値。

x

Operation Timeout (操作タイムアウト)

Number (数値)

実行を開始する操作のタイムアウト。

Operation Timeout Time Unit (操作タイムアウト時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Operation Timeout (操作タイムアウト)]​ 項目の時間単位。

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
#### [](#関連する設定-5)関連する設定 - [Consumer Configuration (コンシューマー設定)](#consumer-config) #### [](#スロー-3)スロー - KAFKA:INVALID\_TOPIC - KAFKA:RETRY\_EXHAUSTED - KAFKA:TIMEOUT - KAFKA:INVALID\_OFFSET - KAFKA:INVALID\_INPUT - KAFKA:NOT\_FOUND - KAFKA:CONNECTIVITY ## [](#producer-操作)Producer 操作 - [Publish](#publish) ### [](#publish)Publish `` 指定された Kafka トピックにメッセージをパブリッシュします。必要に応じて、そのパーティション、キー、メッセージコンテンツを指定します。この操作では、トランザクションがサポートされています。
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Topic (トピック)

String (文字列)

パブリッシュするトピック。

Partition (パーティション)

Number (数値)

(省略可能) トピックパーティション。

Key (キー)

Binary (バイナリ)

(省略可能) パブリッシュされたメッセージのキー。

Message (メッセージ)

Binary (バイナリ)

(省略可能) メッセージのメッセージコンテンツ。

#[payload]

Headers (ヘッダー)

Object (オブジェクト)

(省略可能) メッセージのヘッダー。

Transactional Action (トランザクションアクション)

Enumeration (列挙)。次のいずれかになります。

  • ALWAYS_JOIN​

  • JOIN_IF_POSSIBLE​

  • NOT_SUPPORTED

トランザクションに関する操作で実行できる結合アクションの種別。

JOIN_IF_POSSIBLE

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は ​[Target Variable (対象変数)]​ 項目に保存されます。

#[payload]

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
#### [](#出力-4)出力

型

Kafka Message Metadata (Kafka メッセージのメタデータ)
#### [](#関連する設定-6)関連する設定 - [プロデューサー設定](#producer-config) #### [](#スロー-4)スロー - KAFKA:INVALID\_TOPIC\_PARTITION - KAFKA:RETRY\_EXHAUSTED - KAFKA:TIMEOUT - KAFKA:INPUT\_TOO\_LARGE - KAFKA:CONNECTIVITY ## [](#object-types-オブジェクト種別)Object Types (オブジェクト種別) - [Consumer Context (コンシューマーコンテキスト)](#ConsumerContext) - [CRL File (CRL ファイル)](#CrlFile) - [Custom OCSP Responder (カスタム OCSP レスポンダー)](#CustomOcspResponder) - [Expiration Policy (有効期限ポリシー)](#ExpirationPolicy) - [Kafka Message Metadata (Kafka メッセージのメタデータ)](#KafkaMessageMetadata) - [Kafka Record Attributes (Kafka レコード属性)](#KafkaRecordAttributes) - [Keystore (キーストア)](#KeyStore) - [Reconnect (再接続)](#Reconnect) - [Reconnect Forever (繰り返し再接続)](#Reconnect-Forever) - [Reconnection (再接続)](#Reconnection) - [Record (レコード)](#Record) - [Redelivery Policy (再配信ポリシー)](#RedeliveryPolicy) - [Repeatable File Store Stream (反復可能なファイルストアストリーム)](#RepeatableFileStoreStream) - [Repeatable In Memory Stream (反復可能なメモリ内ストリーム)](#RepeatableInMemoryStream) - [Standard Revocation Check (標準の取り消し確認)](#StandardRevocationCheck) - [TLS](#Tls) - [Topic Partition (トピックパーティション)](#TopicPartition) - [Truststore (トラストストア)](#TrustStore) ### [](#ConsumerContext)Consumer Context (コンシューマーコンテキスト) コンシューマーコンテキストの種別。
項目 型 説明 デフォルト値 必須

Consumer Commit Key (コンシューマーコミットキー)

String (文字列)

コンシューマーコミットキー。
### [](#CrlFile)CRL File (CRL ファイル) 証明書失効リスト (CRL) ファイルの場所を指定します。
項目 型 説明 デフォルト値 必須

Path (パス)

String (文字列)

CRL ファイルへのパス。
### [](#CustomOcspResponder)Custom OCSP Responder (カスタム OCSP レスポンダー) 証明書の取り消し確認のカスタム OCSP レスポンダーを設定します。
項目 型 説明 デフォルト値 必須

Url

String (文字列)

OCSP レスポンダーの URL。

Cert Alias (証明書の別名)

String (文字列)

OCSP 応答の署名証明書の別名。指定した場合、別名はトラストストアに存在する必要があります。
### [](#ExpirationPolicy)Expiration Policy (有効期限ポリシー) 有効期限ポリシー戦略を設定します。
項目 型 説明 デフォルト値 必須

Max Idle Time (最大アイドル時間)

Number (数値)

動的設定インスタンスがアイドル状態を続けられる最大時間を設定します。この時間が経過すると、Mule Runtime で期限切れに相当するとみなされます。

Time Unit (時間単位)

Enumeration (列挙)。次のいずれかになります。

  • NANOSECONDS (ナノ秒)

  • MICROSECONDS (マイクロ秒)

  • MILLISECONDS (ミリ秒)

  • SECONDS (秒)

  • MINUTES (分)

  • HOURS (時間)

  • DAYS (日)

[Max Idle Time (最大アイドル時間)]​ 項目の時間単位。
### [](#KafkaMessageMetadata)Kafka Message Metadata (Kafka メッセージのメタデータ) Kafka メッセージのメタデータ。
項目 型 説明 デフォルト値 必須

オフセット

Number (数値)

メッセージのオフセット。

Partition (パーティション)

Number (数値)

メッセージのパーティション。

Serialized Key Size (シリアル化されたキーのサイズ)

Number (数値)

メッセージのシリアル化されたキーのサイズ。

Serialized Value Size (シリアル化された値のサイズ)

Number (数値)

メッセージのシリアル化された値のサイズ。

Timestamp (タイムスタンプ)

DateTime

メッセージのタイムスタンプ。

Topic (トピック)

String (文字列)

メッセージのトピック。
### [](#KafkaRecordAttributes)Kafka Record Attributes (Kafka レコード属性) Kafka レコードの属性。
項目 型 説明 デフォルト値 必須

Consumer Commit Key (コンシューマーコミットキー)

String (文字列)

コンシューマーコミットキー。

Creation Timestamp (作成時のタイムスタンプ)

DateTime

レコード作成のタイムスタンプ。

Headers (ヘッダー)

Object (オブジェクト)

メッセージ内の HTTP ヘッダーのマッピング。

Key (キー)

Binary (バイナリ)

レコードのキー。

Leader Epoch (リーダーエポック)

Number (数値)

レコードのリーダーエポック。

Log Append Timestamp (ログに追加されるタイムスタンプ)

DateTime

レコードのログに追加されるタイムスタンプ。

オフセット

Number (数値)

レコードのオフセット。

Partition (パーティション)

Number (数値)

レコードのパーティション。

Serialized Key Size (シリアル化されたキーのサイズ)

Number (数値)

レコードのシリアル化されたキーのサイズ。

Serialized Value Size (シリアル化された値のサイズ)

Number (数値)

レコードのシリアル化された値のサイズ。

Topic (トピック)

String (文字列)

レコードのトピック。
### [](#KeyStore)Keystore (キーストア) TLS プロトコル用のキーストアを設定します。生成したキーストアには、非公開鍵と公開証明書が格納されます。
項目 型 説明 デフォルト値 必須

Path (パス)

String (文字列)

キーストアへのパス。Mule では、現在のクラスパスとファイルシステムへの相対的なパスを解決します。

Type (型)

String (文字列)

キーストアの種別。

Alias (別名)

String (文字列)

キーストアに複数の非公開鍵が含まれている場合に使用するキーの別名。デフォルトでは、Mule はファイル内の最初のキーを使用します。

Key Password (キーパスワード)

String (文字列)

非公開鍵を保護するために使用するパスワード。

Password (パスワード)

String (文字列)

キーストアを保護するために使用するパスワード。

Algorithm (アルゴリズム)

String (文字列)

キーストアで使用する暗号化アルゴリズム。
### [](#Reconnect)Reconnect (再接続) 標準再接続戦略を設定し、再接続の頻度と、コネクタソースまたは操作で実行できる再接続の試行回数を指定します。
項目 型 説明 デフォルト値 必須

Frequency (頻度)

Number (数値)

再接続を試行する頻度 (ミリ秒)。

Blocking (ブロック)

Boolean (ブール)

false​ の場合、再接続戦略が個別の非ブロックスレッドで実行されます。

Count (数)

Number (数値)

Mule アプリケーションで実行できる再接続の試行回数。
### [](#Reconnect-Forever)Reconnect Forever (繰り返し再接続) Mule アプリケーションが実行されている間はコネクタソースや操作によって指定された頻度で再接続が試行される Forever 再接続戦略を設定します。
項目 型 説明 デフォルト値 必須

Frequency (頻度)

Number (数値)

再接続を試行する頻度 (ミリ秒)。

Blocking (ブロック)

Boolean (ブール)

false​ の場合、再接続戦略が個別の非ブロックスレッドで実行されます。
### [](#Reconnection)Reconnection (再接続) 操作の再接続戦略を設定します。
項目 型 説明 デフォルト値 必須

Fails Deployment (デプロイメントに失敗)

Boolean (ブール)

アプリケーションのデプロイ時に、関連する再接続戦略をすべて実行した後、接続テストに合格しない場合の処理:

  • true​

    デプロイメントの失敗を許可します。

  • false​

    接続テストの結果を無視します。

Reconnection Strategy (再接続戦略)

使用する再接続戦略。
### [](#Record)Record (レコード) レコードのタイプ。
項目 型 説明 デフォルト値 必須

Attributes (属性)

Kafka Record Attributes (Kafka レコード属性)

Kafka レコード属性。

Payload (ペイロード)

Binary (バイナリ)

レコードのペイロード。
### [](#RedeliveryPolicy)Redelivery Policy (再配信ポリシー) エラーを生成する要求を実行するための再配信ポリシーを設定します。再配信ポリシーは、フロー内のあらゆる提供元に追加できます。
項目 型 説明 デフォルト値 必須

Max Redelivery Count (最大再配信数)

Number (数値)

REDELIVERY_EXHAUSTED​ エラーが返されるまでに、再配信された要求が処理に失敗できる最大回数。

Use Secure Hash (セキュアハッシュを使用)

Boolean (ブール)

true​ の場合、再配信されたメッセージの識別にセキュアハッシュアルゴリズムが使用されます。

Message Digest Algorithm (メッセージダイジェストアルゴリズム)

String (文字列)

[Use Secure Hash (セキュアハッシュを使用)]​ 項目が ​true​ の場合に使用するセキュアハッシュアルゴリズム。メッセージのペイロードが Java オブジェクトの場合、Mule ではこの値が無視され、ペイロードの ​hashCode()​ が返した値が返されます。

Id Expression (ID 式)

String (文字列)

メッセージがいつ再配信されたのかを判断するために使用する 1 つ以上の式を定義します。このプロパティは、​[Use Secure Hash (セキュアハッシュを使用)]​ が ​false​ の場合にのみ設定できます。

Object Store (オブジェクトストア)

ObjectStore

各メッセージの再配信カウンターが保存されるオブジェクトストアを設定します。
### [](#RepeatableFileStoreStream)Repeatable File Store Stream (反復可能なファイルストアストリーム) 反復可能なファイルストアストリーミング戦略を設定します。この戦略では、ストリームコンテンツの一部がメモリ内に格納されます。ストリームのコンテンツが、設定されたバッファサイズよりも大きい場合、Mule はバッファのコンテンツをディスクにバックアップしてからメモリをクリアします。
項目 型 説明 デフォルト値 必須

In Memory Size (メモリ内サイズ)

Number (数値)

ストリームのデータで使用できるメモリの最大量。メモリ量がこの値を超えると、コンテンツはディスクにバッファされます。パフォーマンスを最適化する方法は、次のとおりです。

  • バッファサイズを大きくすると、Mule がバッファをディスクに書き込む回数を減らせます。これによってパフォーマンスが高まりますが、より多くのメモリが必要になるため、アプリケーションが処理できる同時要求数が制限されます。

  • バッファサイズを小さくすると、メモリの負荷は低減しますが、応答時間が長くなります。

Buffer Unit (バッファ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[In Memory Size (メモリ内サイズ)]​ 項目の単位。
### [](#RepeatableInMemoryStream)Repeatable In Memory Stream (反復可能なメモリ内ストリーム) データが最大バッファサイズを超えた場合に要求が失敗するメモリ内ストリーミング戦略を設定します。ユースケースで最適なバッファサイズは、必ずパフォーマンステストを実施して決めてください。
項目 型 説明 デフォルト値 必須

Initial Buffer Size (初期バッファサイズ)

Number (数値)

データストリームに割り当てるメモリの初期容量。ストリーミングされたデータがこの値を超える場合は、​[Buffer Size Increment (バッファサイズ増分)]​ の単位で ​[Max In Memory Size (最大メモリ内サイズ)]​ 値を上限としてバッファが拡張されます。

Buffer Size Increment (バッファサイズ増分)

Number (数値)

バッファサイズが初期サイズを超えた場合に、拡張する量。値を ​0​ またはそれ以下に設定すると、バッファは拡張されません。

Max Buffer Size (最大バッファサイズ)

Number (数値)

使用するメモリの最大量。これを超えると、​STREAM_MAXIMUM_SIZE_EXCEEDED​ エラーが発生します。0 以下の値は無制限を意味します。

Buffer Unit (バッファ単位)

Enumeration (列挙)。次のいずれかになります。

  • BYTE (バイト)

  • KB

  • MB

  • GB

[Initial Buffer Size (初期バッファサイズ)]​ 項目、​[Buffer Size Increment (バッファサイズ増分)]​ 項目、​[Buffer Unit (バッファ単位)]​ 項目の単位。
### [](#StandardRevocationCheck)Standard Revocation Check (標準の取り消し確認) TLS 証明書の標準取り消し確認を設定します。
項目 型 説明 デフォルト値 必須

Only End Entities (最後のエンティティのみ)

Boolean (ブール)

証明書チェーン内で確認する要素:

  • true​

    証明書チェーンの最後の要素のみを確認します。

  • false​

    証明書チェーンのすべての要素を確認します。

Prefer Crls (CRL を優先)

Boolean (ブール)

証明書の有効性を確認する方法:

  • true​

    証明書失効リスト (CRL) で証明書の有効性を確認します。

  • false​

    オンライン証明書状況プロトコル (OCSP) を使用して証明書の有効性を確認します。

No Fallback (代替なし)

Boolean (ブール)

証明書の有効性を確認するための第 2 の方法を使用するかどうか:

  • true​

    [Prefer Crls (CRL を優先)]​ 項目で指定されていない方法 (第 2 の方法) を使用して証明書の有効性を確認します。

  • false​

    証明書の有効性を確認するための第 2 の方法を使用しません。

Soft Fail (ソフトフェール)

Boolean (ブール)

取り消しサーバーに到達できない場合や取り消しサーバーが混雑している場合の処理:

  • true​

    検証エラーを回避します。

  • false​

    検証の失敗を許可します。
### [](#Tls)TLS Mule アプリケーションのセキュアな通信を提供するように TLS を設定します。
項目 型 説明 デフォルト値 必須

Enabled Protocols (有効化されたプロトコル)

String (文字列)

このコンテキストで有効化されたプロトコルのカンマ区切りリスト。

Enabled Cipher Suites (有効化された暗号化スイート)

String (文字列)

このコンテキストで有効化された暗号化スイートのカンマ区切りリスト。

Trust Store (トラストストア)

Truststore (トラストストア)

TLS トラストストアを設定します。

Key Store (キーストア)

Keystore (キーストア)

TLS キーストアを設定します。

Revocation Check (取り消し確認)

取り消し確認メカニズムを設定します。
### [](#TopicPartition)Topic Partition (トピックパーティション) トピックパーティションの種別。
項目 型 説明 デフォルト値 必須

Topic (トピック)

String (文字列)

トピック名。

x

Partition (パーティション)

Number (数値)

パーティションの数。

x
### [](#TrustStore)Truststore (トラストストア) TLS 用のトラストストアを設定します。
項目 型 説明 デフォルト値 必須

Path (パス)

String (文字列)

トラストストアへのパス。Mule では、現在のクラスパスとファイルシステムへの相対的なパスを解決します。

Password (パスワード)

String (文字列)

トラストストアを保護するために使用するパスワード。

Type (型)

String (文字列)

トラストストアの型。

Algorithm (アルゴリズム)

String (文字列)

トラストストアで使用する暗号化アルゴリズム。

Insecure (安全ではない)

Boolean (ブール)

true​ の場合、Mule では証明書の検証の実行を停止します。これを ​true​ に設定すると、接続が攻撃に対して脆弱になる可能性があります。
## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [MuleSoft ヘルプセンター](https://help.mulesoft.com)