--- schema_version: "1" id: 291d278687a4f30deeb2b8cf8fde9d9f250acd0bc71824ba8247c4c1fa68c478 title: Apache Kafka Connector 4.4 リファレンス collection: mulesoft version: current locale: ja-jp portal_url: https://docs.salesforce.com/mulesoft/current/ja-jp/kafka-connector/4.4/kafka-connector-reference.md canonical_url: https://docs.mulesoft.com/jp/kafka-connector/4.4/kafka-connector-reference source_site: docs.mulesoft.com content_type: documentation content_hash: ef6e18854114aaf4067172b1924141ea6186deec15719d5dcbf4351dcad41c1c description: MuleSoft Documentation Site release: "4.4" latest: false --- # Apache Kafka Connector 4.4 リファレンス 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 (コンシューマー設定) #### [](#パラメーター)パラメーター
名前 型 説明 デフォルト値 必須

Name (名前)

String (文字列)

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

x

Connection (接続)

この設定に指定する接続型。

x

Name (名前)

String (文字列)

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

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

ポーリングタイムアウトの時間単位。これは、ポーリングの合計タイムアウトを定義するために pollTimeout と共に使用されます。

MILLISECONDS

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

Number (数値)

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

-1

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

操作タイムアウトの時間単位。これは、この設定を使用する操作のデフォルトの合計タイムアウトを定義するために operationTimeout と共に使用されます。

SECONDS

Zone ID (ゾーン ID)

String (文字列)

結果で指定のタイムスタンプを ​ZonedLocalDateTimes​ に変換します。デフォルト値は、システムによって提供されます。
#### [](#接続種別)接続種別 ##### [](#consumer-plaintext)Consumer Plaintext Connection (コンシューマープレーンテキスト接続) ###### [](#パラメーター-2)パラメーター
名前 型 説明 デフォルト値 必須

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

要求タイムアウトスカラーの時間単位を決定します。このパラメーターはソースレベルで上書きできます。

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

再接続バックオフタイムアウトスカラーの時間単位を決定します。

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

受信バッファサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

KB

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

Number (数値)

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

128

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

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

  • BYTE (バイト)

  • KB

  • MB

  • GB

送信バッファサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

KB

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

Number (数値)

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

30

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

要求タイムアウトスカラーの時間単位を決定します。このパラメーターはソースレベルで上書きできます。

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​ に設定されていると、各エントリが解決されて、正規名のリストに展開されます。

DEFAULT

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

Number (数値)

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

3

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

ハートビート間隔時間スカラーをフェッチする時間単位を決定します。

SECONDS

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

Number (数値)

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

10

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

セッションタイムアウトスカラーの時間単位を決定します。

SECONDS

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

Number (数値)

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

540

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

接続の最大アイドル時間スカラーの時間単位。

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

デフォルトの最小フェッチサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

BYTE

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

Number (数値)

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

1

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

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

  • BYTE (バイト)

  • KB

  • MB

  • GB

デフォルトの最大フェッチサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

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

最大パーティションフェッチサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

MB

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

Number (数値)

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

500

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

フェッチの最大待機タイムアウトスカラーの時間単位。

MILLISECONDS

Reconnection (再接続)

Reconnection (再接続)

アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。​true​ に設定されている場合、関連する再接続戦略をすべて実行した後にテストに合格しないと、デプロイメントが失敗します。
##### [](#consumer-sasl-kerberos)Consumer Kerberos Connection (コンシューマー Kerberos 接続) ###### [](#パラメーター-3)パラメーター
名前 型 説明 デフォルト値 必須

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

Array of String (文字列の配列)

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

x

Group ID (グループ ID)

String (文字列)

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

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

Number (数値)

接続で最初に作成されるコンシューマーの数。

1

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

Number (数値)

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

300

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

要求タイムアウトスカラーの時間単位。このパラメーターはソースレベルで上書きできます。

SECONDS

Isolation Level (分離レベル)

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

  • READ_UNCOMMITTED​

  • READ_COMMITTED

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

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

  • READ_UNCOMMITTED​ に設定すると、​consumer.poll()​ で、中止されたトランザクションメッセージを含む、すべてのメッセージが返されます。

    非トランザクションメッセージは、どちらのモードでも無条件に返されます。

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

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

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

再接続バックオフタイムアウトスカラーの時間単位。

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

受信バッファサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

KB

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

Number (数値)

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

128

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

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

  • BYTE (バイト)

  • KB

  • MB

  • GB

送信バッファサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

KB

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

Number (数値)

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

30

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

要求タイムアウトスカラーの時間単位。このパラメーターはソースレベルで上書きできます。

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​ に設定されていると、各エントリが解決されて、正規名のリストに展開されます。

DEFAULT

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

Number (数値)

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

3

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

ハートビート間隔時間スカラーをフェッチする時間単位。

SECONDS

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

Number (数値)

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

10

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

セッションタイムアウトスカラーの時間単位。

SECONDS

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

Number (数値)

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

540

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

接続の最大アイドル時間スカラーの時間単位。

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

デフォルトの最小フェッチサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

BYTE

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

Number (数値)

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

1

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

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

  • BYTE (バイト)

  • KB

  • MB

  • GB

デフォルトの最大フェッチサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

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

最大パーティションフェッチサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

MB

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

Number (数値)

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

500

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

フェッチの最大待機タイムアウトスカラーの時間単位。

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 (再接続)

アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。true に設定されている場合、関連する再接続戦略をすべて実行した後にテストに合格しないと、デプロイメントが失敗します。
##### [](#consumer-sasl-scram)Consumer SASL/SCRAM Connection (コンシューマー SASL/SCRAM 接続) ###### [](#パラメーター-4)パラメーター
名前 型 説明 デフォルト値 必須

username (ユーザー名)

String (文字列)

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

x

password (パスワード)

String (文字列)

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

x

encryptionType

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

  • SHA256

  • SHA512

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

x

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

Array of String (文字列の配列)

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

x

Group ID (グループ ID)

String (文字列)

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

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

Number (数値)

接続で最初に作成されるコンシューマーの数。

1

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

Number (数値)

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

300

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

要求タイムアウトスカラーの時間単位。このパラメーターはソースレベルで上書きできます。

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

再接続バックオフタイムアウトスカラーの時間単位。

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

受信バッファサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

KB

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

Number (数値)

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

128

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

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

  • BYTE (バイト)

  • KB

  • MB

  • GB

送信バッファサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

KB

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

Number (数値)

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

30

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

要求タイムアウトスカラーの時間単位。このパラメーターはソースレベルで上書きできます。

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​ に設定されていると、各エントリが解決されて、正規名のリストに展開されます。

DEFAULT

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

Number (数値)

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

3

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

ハートビート間隔時間スカラーをフェッチする時間単位。

SECONDS

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

Number (数値)

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

10

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

セッションタイムアウトスカラーの時間単位。

SECONDS

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

Number (数値)

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

540

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

接続の最大アイドル時間スカラーの時間単位。

SECONDS

TLS Configuration (TLS 設定)

TLS

Mule アプリケーションの通信を保護するためにクライアント側とサーバー側の両方から使用できる TLS の設定を定義します。HTTPS プロトコルを使用すると、HTTP 通信が TLS または SSL を使用して保護されます。プロトコルとして HTTPS が設定されている場合、ユーザーは ​listener-config​ の ​tls:context​ 子要素で少なくともキーストアを設定する必要があります。

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

最小パーティションフェッチサイズスカラーの測定単位。

BYTE

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

Number (数値)

フェッチ要求に対してサーバーが返す必要のあるデータの最大量。コンシューマーは、まとめてレコードをフェッチします。フェッチの最初の空でないパーティションの最初のレコードバッチがこの値より大きい場合でも、コンシューマーが処理を続行できるようにレコードバッチが返されます。そのため、これは絶対最大値ではありません。

ブローカーで受け入れられる最大レコードバッチサイズは、​message.max.bytes​ (ブローカー設定) または ​max.message.bytes​ (トピック設定) を使用して定義されます。コンシューマーは複数のフェッチを並列で実行します。このパラメーターはソースレベルで上書きできます。

1

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

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

  • BYTE (バイト)

  • KB

  • MB

  • GB

最大パーティションフェッチサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

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

最大パーティションフェッチサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

MB

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

Number (数値)

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

500

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

フェッチの最大待機タイムアウトスカラーの時間単位。

MILLISECONDS

Reconnection (再接続)

Reconnection (再接続)

アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。​true​ に設定されている場合、関連する再接続戦略をすべて実行した後にテストに合格しないと、デプロイメントが失敗します。
#### [](#consumer-sasl-plain)Consumer SASL/PLAIN Connection (コンシューマー SASL/SCRAM 接続) ##### [](#パラメーター-5)パラメーター
名前 型 説明 デフォルト値 必須

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

Array of String (文字列の配列)

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

x

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

String (文字列)

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

Group ID (グループ ID)

String (文字列)

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

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

Number (数値)

接続で最初に作成されるコンシューマーの数。

1

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

Number (数値)

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

300

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

要求タイムアウトスカラーの時間単位。このパラメーターはソースレベルで上書きできます。

SECONDS

Isolation Level (分離レベル)

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

  • READ_UNCOMMITTED​

  • READ_COMMITTED

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

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

  • READ_UNCOMMITTED​ に設定すると、​consumer.poll()​ で、中止されたトランザクションメッセージを含む、すべてのメッセージが返されます。

    非トランザクションメッセージは、どちらのモードでも無条件に返されます。

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

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

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

再接続バックオフタイムアウトスカラーの時間単位。

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

受信バッファサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

KB

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

Number (数値)

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

128

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

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

  • BYTE (バイト)

  • KB

  • MB

  • GB

送信バッファサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

KB

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

Number (数値)

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

30

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

要求タイムアウトスカラーの時間単位。このパラメーターはソースレベルで上書きできます。

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​ に設定されていると、各エントリが解決されて、正規名のリストに展開されます。

DEFAULT

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

Number (数値)

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

3

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

ハートビート間隔時間スカラーをフェッチする時間単位。

SECONDS

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

Number (数値)

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

10

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

セッションタイムアウトスカラーの時間単位。

SECONDS

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

Number (数値)

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

540

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

接続の最大アイドル時間スカラーの時間単位。

SECONDS

TLS Configuration (TLS 設定)

TLS

Mule アプリケーションの通信を保護するためにクライアント側とサーバー側の両方から使用できる TLS 設定を定義します。HTTPS プロトコルを使用すると、HTTP 通信が TLS または SSL を使用して保護されます。プロトコルとして HTTPS が設定されている場合、ユーザーはこの ​listener-config​ の ​tls:context​ 子要素で少なくともキーストアを設定する必要があります。

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

デフォルトの最小フェッチサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

BYTE

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

Number (数値)

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

1

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

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

  • BYTE (バイト)

  • KB

  • MB

  • GB

デフォルトの最大フェッチサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

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

最大パーティションフェッチサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

MB

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

Number (数値)

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

500

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

フェッチの最大待機タイムアウトスカラーの時間単位。

MILLISECONDS

Username (ユーザー名)

String (文字列)

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

x

Password (パスワード)

String (文字列)

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

x

Reconnection (再接続)

Reconnection (再接続)

アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。true に設定されている場合、関連する再接続戦略をすべて実行した後にテストに合格しないと、デプロイメントが失敗します。
* * * ### [](#producer-config)プロデューサー設定 #### [](#パラメーター-6)パラメーター
名前 型 説明 デフォルト値 必須

Name (名前)

String (文字列)

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

x

Connection (接続)

この設定に指定する接続型。

x

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

String (文字列)

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

defaultTopicName

Zone ID (ゾーン ID)

String (文字列)

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

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

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

動的設定インスタンスがアイドル状態を続けられる最小時間を設定します。この時間が経過すると、Mule Runtime Engine (Mule) で期限切れに相当するとみなされます。インスタンスが期限切れとみなされた瞬間にインスタンスが期限切れになるという意味ではありません。必要に応じて、インスタンスがパージされます。
#### [](#接続種別-2)接続種別 ##### [](#producer-plaintext)Producer Plaintext Connection (プロデューサープレーンテキスト接続) ###### [](#パラメーター-7)パラメーター
名前 型 説明 デフォルト値 必須

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

バッチサイズスカラーの測定単位。

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

最大要求サイズスカラーの測定単位。

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​ の場合、各エントリが解決されて、正規名のリストに展開されます。

DEFAULT

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

接続の最大アイドル時間スカラーの時間単位を決定します。

SECONDS

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

Number (数値)

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

120

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

配信タイムアウトスカラーの時間単位を決定します。

SECONDS

Enable idempotence (冪等性を有効化)

Boolean (ブール)

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

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

延長時間スカラーの時間単位を決定します。

SECONDS

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

Number (数値)

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

60

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

最大ブロック時間スカラーの時間単位を決定します。

SECONDS

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

Number (数値)

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

5

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

Number (数値)

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

1

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

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

  • BYTE (バイト)

  • KB

  • MB

  • GB

最大要求サイズスカラーの測定単位。

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

受信バッファサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

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 (数値)

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

1000

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

再接続バックオフタイムアウトスカラーの時間単位を決定します。

MILLISECONDS

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

Number (数値)

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

128

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

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

  • BYTE (バイト)

  • KB

  • MB

  • GB

送信バッファサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

KB

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

Number (数値)

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

30

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

要求のタイムアウト時間単位。

SECONDS

TLS Configuration (TLS 設定)

TLS

Mule アプリケーションの通信を保護するためにクライアント側とサーバー側の両方から使用できる TLS の設定を定義します。HTTPS プロトコルを使用すると、HTTP 通信が TLS または SSL を使用して保護されます。プロトコルとして HTTPS が設定されている場合、ユーザーは ​listener-config​ の ​tls:context​ 子要素で少なくともキーストアを設定する必要があります。

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

String (文字列)

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

Reconnection (再接続)

Reconnection (再接続)

アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。​true​ に設定されている場合、関連する再接続戦略をすべて実行した後にテストに合格しないと、デプロイメントが失敗します。
##### [](#producer-sasl-kerberos)Producer Kerberos Connection (プロデューサー Kerberos 接続) ###### [](#パラメーター-8)パラメーター
名前 型 説明 デフォルト値 必須

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

バッチサイズスカラーの測定単位。

KB

Buffer size (バッファサイズ)

Number (数値)

サーバーに送信されるのを待機しているレコードをバッファするためにプロデューサーが使用できるメモリの合計バイト。配信できるようになる前にレコードが送信されると、プロデューサーは ​max.block.ms​ の間ブロックされ、この期間が経過すると例外がスローされます。通常、この設定はプロデューサーが使用する合計メモリに対応しますが、プロデューサーが使用するメモリはバッファに使用されないこともあります。プロデューサーは、追加メモリを圧縮 (有効になっている場合) やインフライト要求の管理に使用します。

Kafka のデフォルト値は ​33554432​ (32MB) ですが、CloudHub (v0.1 コア) の Mule インスタンスの想定値に合わせてこの値に上限を設定する必要があります。

1000

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

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

  • BYTE (バイト)

  • KB

  • MB

  • GB

最大要求サイズスカラーの測定単位。

KB

DNS lookups (DNS ルックアップ)

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

  • DEFAULT

  • USE_ALL_DNS_IPS​

  • RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY

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

  • DEFAULT (デフォルト): Kafka のデフォルトを使用します。

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

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

DEFAULT

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

接続の最大アイドルスカラーの時間単位。

SECONDS

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

Number (数値)

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

120

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS0

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

配信タイムアウトスカラーの時間単位を決定します。

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

延長時間スカラーの時間単位。

SECONDS

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

Number (数値)

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

60

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

最大ブロック時間スカラーの時間単位。

SECONDS

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

Number (数値)

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

5

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

Number (数値)

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

1

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

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

  • BYTE (バイト)

  • KB

  • MB

  • GB

最大要求サイズスカラーの測定単位。

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

受信バッファサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

KB

Retries amount (再試行回数)

Number (数値)

0 より大きな値を設定すると、クライアントは一時的なエラーで送信に失敗した可能性のあるレコードを再送信します。この再試行は、エラーが発生したときにクライアントにレコードを再送信させる場合と同じです。​max.in.flight.requests.per.connection​ を ​1​ に設定せずに再試行できるようにすると、次の場合にレコードの順序が変更される可能性があります。

  • 2 つのバッチが 1 つのパーティションに送信される

  • 最初のバッチが失敗して再試行される

  • 2 番目のバッチが成功する

    肯定応答に成功する前に ​delivery.timeout.ms​ で設定されたタイムアウトの期限が切れると、プロデューサーの要求は再試行回数に達する前に失敗します。この値を未設定のままにして、​delivery.timeout.ms​ を使用して再試行の動作を制御することをお勧めします。

1

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

再試行バックオフタイムアウト時間スカラーの時間単位。

MILLISECONDS

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

Number (数値)

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

100

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

Number (数値)

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

128

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

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

  • BYTE (バイト)

  • KB

  • MB

  • GB

送信バッファサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

KB

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

要求タイムアウト時間スカラーの時間単位。

SECONDS

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

Number (数値)

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

30

TLS Configuration (TLS 設定)

TLS

通信に使用するプロトコル。有効な値は HTTP (デフォルト) と HTTPS です。HTTPS を使用すると、HTTP 通信が TLS または SSL を使用して保護されます。プロトコルとして HTTPS が設定されている場合、ユーザーはこの ​listener-config​ の ​tls:context​ 子要素で少なくともキーストアを設定する必要があります。

Reconnection (再接続)

Reconnection (再接続)

アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。true に設定されている場合、関連する再接続戦略をすべて実行した後にテストに合格しないと、デプロイメントが失敗します。
##### [](#producer-sasl-scram)Producer SASL/SCRAM Connection (プロデューサー SASL/SCRAM 接続) ###### [](#パラメーター-9)パラメーター
名前 型 説明 デフォルト値 必須

Username (ユーザー名)

String (文字列)

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

x

Password (パスワード)

String (文字列)

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

x

EncryptionType

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

  • SHA256

  • SHA512

SCRAM で使用される暗号化アルゴリズム。有効な値は SHA-256 と SHA-512 のみです。

x

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

バッチサイズスカラーの測定単位。

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

最大要求サイズスカラーの測定単位。

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​ の場合、各エントリが解決されて、正規名のリストに展開されます。

DEFAULT

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

接続の最大アイドル時間スカラーの時間単位を決定します。

SECONDS

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

Number (数値)

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

120

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

配信タイムアウトスカラーの時間単位を決定します。

SECONDS

Enable idempotence (冪等性を有効化)

Boolean (ブール)

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

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

延長時間スカラーの時間単位を決定します。

SECONDS

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

Number (数値)

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

60

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

最大ブロック時間スカラーの時間単位を決定します。

SECONDS

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

Number (数値)

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

5

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

Number (数値)

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

1

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

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

  • BYTE (バイト)

  • KB

  • MB

  • GB

最大要求サイズスカラーの測定単位。

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

受信バッファサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

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 (数値)

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

1000

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

再接続バックオフタイムアウトスカラーの時間単位を決定します。

MILLISECONDS

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

Number (数値)

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

128

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

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

  • BYTE (バイト)

  • KB

  • MB

  • GB

送信バッファサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

KB

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

Number (数値)

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

30

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

要求のタイムアウト時間単位。

SECONDS

TLS Configuration (TLS 設定)

TLS

Mule アプリケーションの通信を保護するためにクライアント側とサーバー側の両方から使用できる TLS の設定を定義します。HTTPS プロトコルを使用すると、HTTP 通信が TLS または SSL を使用して保護されます。プロトコルとして HTTPS が設定されている場合、ユーザーは ​listener-config​ の ​tls:context​ 子要素で少なくともキーストアを設定する必要があります。

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

String (文字列)

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

Reconnection (再接続)

Reconnection (再接続)

アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。​true​ に設定されている場合、関連する再接続戦略をすべて実行した後にテストに合格しないと、デプロイメントが失敗します。
##### [](#producer-sasl-plain)Producer SASL/PLAIN Connection (プロデューサー SASL/SCRAM 接続) ###### [](#パラメーター-10)パラメーター
名前 型 説明 デフォルト値 必須

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

Array of String (文字列の配列)

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

x

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

String (文字列)

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

Batch size (バッチサイズ)

Number (数値)

複数のレコードが同じパーティションに送信される場合、プロデューサーはレコードをより少ない要求にまとめようとします。これは、クライアントとサーバーの両方のパフォーマンスに寄与します。このパラメーターでは、デフォルトのバッチサイズをバイト単位で制御します。このサイズより大きなレコードはまとめられません。

ブローカーに送信される要求には、送信可能なデータが含まれるバッチがあり、1 つのバッチは各パーティションに対応します。バッチサイズが小さいと、一括処理の頻度が高くなり、スループットが低下する可能性があります。バッチサイズが 0 の場合、一括処理は完全に無効になります。コネクタはレコードが追加されることを想定して指定のバッチサイズのバッファを割り当てるため、バッチサイズが非常に大きいと、メモリの使用効率が下がる可能性があります。

16

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

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

  • BYTE (バイト)

  • KB

  • MB

  • GB

バッチサイズスカラーの測定単位。

KB

Buffer size (バッファサイズ)

Number (数値)

サーバーに送信されるのを待機しているレコードをバッファするためにプロデューサーが使用できるメモリの合計バイト。配信できるようになる前にレコードが送信されると、プロデューサーは ​max.block.ms​ の間ブロックされ、この期間が経過すると例外がスローされます。通常、この設定はプロデューサーが使用する合計メモリに対応しますが、プロデューサーが使用するメモリはバッファに使用されないこともあります。プロデューサーは、追加メモリを圧縮 (有効になっている場合) やインフライト要求の管理に使用します。

Kafka のデフォルト値は ​33554432​ (32MB) ですが、CloudHub (v0.1 コア) の Mule インスタンスの想定値に合わせてこの値に上限を設定する必要があります。

1000

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

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

  • BYTE (バイト)

  • KB

  • MB

  • GB

最大要求サイズスカラーの測定単位。

KB

DNS lookups (DNS ルックアップ)

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

  • DEFAULT

  • USE_ALL_DNS_IPS​

  • RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY

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

  • DEFAULT (デフォルト): Kafka のデフォルトを使用します。

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

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

DEFAULT

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

接続の最大アイドルスカラーの時間単位。

SECONDS

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

Number (数値)

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

120

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS0

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

配信タイムアウトスカラーの時間単位を決定します。

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

延長時間スカラーの時間単位。

SECONDS

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

Number (数値)

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

60

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

最大ブロック時間スカラーの時間単位。

SECONDS

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

Number (数値)

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

5

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

Number (数値)

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

1

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

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

  • BYTE (バイト)

  • KB

  • MB

  • GB

最大要求サイズスカラーの測定単位。

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

受信バッファサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

KB

Retries amount (再試行回数)

Number (数値)

0 より大きな値を設定すると、クライアントは一時的なエラーで送信に失敗した可能性のあるレコードを再送信します。この再試行は、エラーが発生したときにクライアントにレコードを再送信させる場合と同じです。​max.in.flight.requests.per.connection​ を ​1​ に設定せずに再試行できるようにすると、次の場合にレコードの順序が変更される可能性があります。

  • 2 つのバッチが 1 つのパーティションに送信される

  • 最初のバッチが失敗して再試行される

  • 2 番目のバッチが成功する

    肯定応答に成功する前に ​delivery.timeout.ms​ で設定されたタイムアウトの期限が切れると、プロデューサーの要求は再試行回数に達する前に失敗します。この値を未設定のままにして、​delivery.timeout.ms​ を使用して再試行の動作を制御することをお勧めします。

1

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

再試行バックオフタイムアウト時間スカラーの時間単位。

MILLISECONDS

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

Number (数値)

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

100

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

Number (数値)

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

128

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

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

  • BYTE (バイト)

  • KB

  • MB

  • GB

送信バッファサイズスカラーの測定単位。このパラメーターはソースレベルで上書きできます。

KB

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

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

要求タイムアウト時間スカラーの時間単位。

SECONDS

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

Number (数値)

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

30

TLS Configuration (TLS 設定)

TLS

通信に使用するプロトコル。有効な値は HTTP (デフォルト) と HTTPS です。HTTPS を使用すると、HTTP 通信が TLS または SSL を使用して保護されます。プロトコルとして HTTPS が設定されている場合、ユーザーはこの ​listener-config​ の ​tls:context​ 子要素で少なくともキーストアを設定する必要があります。

Username (ユーザー名)

String (文字列)

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

x

Password (パスワード)

String (文字列)

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

x

Reconnection (再接続)

Reconnection (再接続)

アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。true に設定されている場合、関連する再接続戦略をすべて実行した後にテストに合格しないと、デプロイメントが失敗します。
## [](#コンシューマーソース)コンシューマーソース ### [](#batch-message-listener)Batch Message Listener `` このソースでは、Kafka クラスターからのメッセージのコンシュームがサポートされており、フローへのメッセージのリストが生成されます。 #### [](#パラメーター-11)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Poll timeout (ポーリングタイムアウト)

Number (数値)

ブロックする時間。ポーリングの合計タイムアウトを定義します。

Poll timeout time unit (ポーリングタイムアウト時間単位)

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

ポーリングタイムアウトの時間単位。ポーリングの合計タイムアウトを定義するためにポーリングタイムアウトと共に使用されます。

Acknowledgment mode (肯定応答モード)

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

  • AUTO

  • MANUAL

  • IMMEDIATE

  • DUPS_OK

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

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

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

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

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

Number of parallel consumers (並列コンシューマー数)。

Number (数値)

1

Primary Node Only (プライマリノードのみ)

Boolean (ブール)

クラスターでの実行時、このソースをプライマリノード上でのみ実行する必要があるかどうか。

Redelivery Policy (再配信ポリシー)

Redelivery Policy (再配信ポリシー)

同じメッセージの再配信を処理するためのポリシーを定義します。

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
#### [](#出力)出力

型

Record (レコード)​ の配列

Attributes Type (属性型)

Consumer Context (コンシューマーコンテキスト)
### [](#次の設定の場合)次の設定の場合 - [Consumer Configuration (コンシューマー設定)](#consumer-config)
Batch Message Listener​ ソースでは、入力ストリームとしてレコードのバッチを取得するため、設定可能なストリーミング戦略がサポートされません。デフォルトでは、このソースのストリーミング戦略設定は反復不可能ストリームです。
### [](#message-listener)Message Listener `` このソースでは、Kafka クラスターからのメッセージのコンシュームがサポートされており、フローへの 1 つのメッセージが生成されます。 #### [](#パラメーター-12)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Poll timeout (ポーリングタイムアウト)

Number (数値)

ブロックする時間。ポーリングの合計タイムアウトを定義します。

Poll timeout time unit (ポーリングタイムアウト時間単位)

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

ポーリングタイムアウトの時間単位。ポーリングの合計タイムアウトを定義するためにポーリングタイムアウトと共に使用されます。

Acknowledgment mode (肯定応答モード)

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

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

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

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

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

  • DUPS_OK​: [MANUAL (手動)] モードと同様に動作しますが、非同期でコミットが行われるため、レコードが重複する可能性があります。

Number of parallel consumers (並列コンシューマー数)

Number (数値)

1

Primary Node Only (プライマリノードのみ)

Boolean (ブール)

クラスターでの実行時、このソースをプライマリノード上でのみ実行する必要があるかどうか。

Streaming Strategy (ストリーミング戦略)

反復可能なストリームを使用するように設定します。

Redelivery Policy (再配信ポリシー)

Redelivery Policy (再配信ポリシー)

同じメッセージの再配信を処理するためのポリシーを定義します。

Reconnection Strategy (再接続戦略)

接続エラーが発生した場合の再試行戦略。
#### [](#出力-2)出力

型

Binary (バイナリ)

Attributes Type (属性型)

Kafka Record Attributes (Kafka レコード属性)
### [](#次の設定の場合-2)次の設定の場合 - [Consumer Configuration (コンシューマー設定)](#consumer-config) ## [](#コンシューマー操作)コンシューマー操作 ### [](#commit)Commit `` メッセージリスナーがコンシュームされるメッセージまたはメッセージのバッチに関連付けられているオフセットをコミットします。これは、BatchMessageListenerSource でコンシュームされるメッセージのリストまたは 1 つのメッセージになります。 #### [](#パラメーター-13)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Consumer commit key (コンシューマーコミットキー)

String (文字列)

前回のポーリングの commitKey。この操作は、この値を Mule イベントの属性として挿入するいずれかの MessageListenerSource(s) ( BatchMessageListenerSource / BatchMessageListenerSource) を使用するフロー内で使用される場合にのみ有効です。

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 トピックからメッセージを受信できます。この機能は、メッセージリスナーソースと非常に似ているため、それに適用されるすべての操作がこの操作にも適用されます。 注意: Consume 操作では ​`consumerCommitKey`​ は返されません。 #### [](#パラメーター-14)パラメーター
名前 型 説明 デフォルト値 必須

Configuration (設定)

String (文字列)

使用する設定の名前。

x

Consumption timeout (コンシュームタイムアウト)

Number (数値)

この操作でメッセージの受信を待機する TimeUnits の数値。

Timeout time unit (タイムアウト時間単位)

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

タイムアウトプロパティの時間単位。

Operation Timeout (操作タイムアウト)

Number (数値)

Operation Timeout Time Unit (操作タイムアウト時間単位)

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

Acknowledgement mode (肯定応答モード)

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

  • AUTO

  • MANUAL

  • IMMEDIATE

  • DUPS_OK

Acknowledgement mode (肯定応答モード):

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

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

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

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

IMMEDIATE

Streaming Strategy (ストリーミング戦略)

反復可能なストリームを使用するように設定します。

Target Variable (対象変数)

String (文字列)

操作の出力を保存する変数の名前。

Target Value (対象値)

String (文字列)

操作の出力を評価する式。式の結果は対象変数に保存されます。

#[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 `` 特定のトピックおよびパーティションのコンシューマーの現在のオフセットを指定のオフセット値に設定します。 #### [](#パラメーター-15)パラメーター
名前 型 説明 デフォルト値 必須

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

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 `` 指定された Kafka トピックにメッセージをパブリッシュします。必要に応じて、そのパーティション、キー、メッセージコンテンツを指定します。publish 操作では、トランザクションがサポートされています。 #### [](#パラメーター-16)パラメーター
名前 型 説明 デフォルト値 必須

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 (文字列)

操作の出力を評価する式。式の結果は対象変数に保存されます。

#[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 ## [](#型)型 ### [](#Tls)TLS
項目 型 説明 デフォルト値 必須

Enabled Protocols (有効化されたプロトコル)

String (文字列)

このコンテキストで有効化されたプロトコルのカンマ区切りリスト。

Enabled Cipher Suites (有効化された暗号化スイート)

String (文字列)

このコンテキストで有効化された暗号化スイートのカンマ区切りリスト。

Trust Store (トラストストア)

Truststore (トラストストア)

Key Store (キーストア)

Key Store (キーストア)

Revocation Check (取り消し確認)
### [](#TrustStore)Truststore (トラストストア)
項目 型 説明 デフォルト値 必須

Path (パス)

String (文字列)

トラストストアの場所 (可能な場合、現在のクラスパスとファイルシステムを基準として解決されます)。

Password (パスワード)

String (文字列)

トラストストアを保護するために使用するパスワード。

Type (型)

String (文字列)

使用するストアの型。

Algorithm (アルゴリズム)

String (文字列)

トラストストアで使用するアルゴリズム。

Insecure (安全ではない)

Boolean (ブール)

true の場合、証明書の検証が実行されず、攻撃に対して接続が脆弱になります。各自の責任で使用してください。
### [](#KeyStore)Key Store (キーストア)
項目 型 説明 デフォルト値 必須

Path (パス)

String (文字列)

キーストアの場所 (可能な場合、現在のクラスパスとファイルシステムを基準として解決されます)。

Type (型)

String (文字列)

使用するストアの型。

Alias (別名)

String (文字列)

キーストアに多数の非公開キーがある場合、この属性は、使用するキーの別名を示します。定義しない場合、デフォルトでファイル内の最初の鍵が使用されます。

Key Password (キーパスワード)

String (文字列)

非公開キーを保護するために使用するパスワード。

Password (パスワード)

String (文字列)

キーストアを保護するために使用するパスワード。

Algorithm (アルゴリズム)

String (文字列)

キーストアで使用するアルゴリズム。
### [](#standard-revocation-check)Standard Revocation Check (標準の取り消し確認)
項目 型 説明 デフォルト値 必須

Only End Entities (最後のエンティティのみ)

Boolean (ブール)

証明書チェーンの最後の要素のみを確認します。

Prefer Crls (CRL を優先)

Boolean (ブール)

最初に OCSP ではなく CRL を試みます。

No Fallback (代替なし)

Boolean (ブール)

第 2 の確認方法 (以前に選択されていない方法) を使用しません。

Soft Fail (ソフトフェール)

Boolean (ブール)

取り消しサーバーに到達できない場合や取り消しサーバーが混雑している場合に検証エラーを回避します。
### [](#custom-ocsp-responder)Custom OCSP Responder (カスタム OCSP レスポンダー)
項目 型 説明 デフォルト値 必須

Url

String (文字列)

OCSP レスポンダーの URL。

Cert Alias (証明書の別名)

String (文字列)

(トラストストアに含まれている) OCSP 応答の署名証明書の別名 (存在する場合)。
### [](#crl-file)CRL File (CRL ファイル)
項目 型 説明 デフォルト値 必須

Path (パス)

String (文字列)

CRL ファイルへのパス。
### [](#TopicPartition)Topic Partition (トピックパーティション)
項目 型 説明 デフォルト値 必須

Topic (トピック)

String (文字列)

x

Partition (パーティション)

Number (数値)

x
### [](#Reconnection)Reconnection (再接続)
項目 型 説明 デフォルト値 必須

Fails Deployment (デプロイメントに失敗)

Boolean (ブール)

アプリケーションがデプロイされると、すべてのコネクタで接続テストが実行されます。true に設定されている場合、関連する再接続戦略をすべて実行した後にテストに合格しないと、デプロイメントが失敗します。

Reconnection Strategy (再接続戦略)

使用する再接続戦略。
### [](#reconnect)Reconnect (再接続)
項目 型 説明 デフォルト値 必須

Frequency (頻度)

Number (数値)

再接続する頻度 (ミリ秒)。

Count (数)

Number (数値)

再接続の試行回数。

blocking (ブロック)

Boolean (ブール)

false の場合、再接続戦略が個別の非ブロックスレッドで実行されます。

true
### [](#reconnect-forever)Reconnect Forever (繰り返し再接続)
項目 型 説明 デフォルト値 必須

Frequency (頻度)

Number (数値)

再接続する頻度 (ミリ秒)。

blocking (ブロック)

Boolean (ブール)

false​ の場合、再接続戦略が個別の非ブロックスレッドで実行されます。

true
### [](#Record)Record (レコード)
項目 型 説明 デフォルト値 必須

Attributes (属性)

Kafka Record Attributes (Kafka レコード属性)

Payload (ペイロード)

Binary (バイナリ)
### [](#KafkaRecordAttributes)Kafka Record Attributes (Kafka レコード属性)
項目 型 説明 デフォルト値 必須

Consumer Commit Key (コンシューマーコミットキー)

String (文字列)

Creation Timestamp (作成時のタイムスタンプ)

DateTime

Headers (ヘッダー)

Object (オブジェクト)

Key (キー)

Binary (バイナリ)

Leader Epoch (リーダーエポック)

Number (数値)

Log Append Timestamp (ログに追加されるタイムスタンプ)

DateTime

オフセット

Number (数値)

Partition (パーティション)

Number (数値)

Serialized Key Size (シリアル化されたキーのサイズ)

Number (数値)

Serialized Value Size (シリアル化された値のサイズ)

Number (数値)

Topic (トピック)

String (文字列)
### [](#ConsumerContext)Consumer Context (コンシューマーコンテキスト)
項目 型 説明 デフォルト値 必須

Consumer Commit Key (コンシューマーコミットキー)

String (文字列)
### [](#RedeliveryPolicy)Redelivery Policy (再配信ポリシー)
項目 型 説明 デフォルト値 必須

Max Redelivery Count (最大再配信数)

Number (数値)

正常に処理されずにプロセス失敗メッセージがトリガーされるまでにメッセージを再配信できる最大回数。

Use Secure Hash (セキュアハッシュを使用)

Boolean (ブール)

再配信されたメッセージの識別にセキュアハッシュアルゴリズムを使用するかどうか。

Message Digest Algorithm (メッセージダイジェストアルゴリズム)

String (文字列)

使用するセキュアハッシュアルゴリズム。

SHA-256

Id Expression (ID 式)

String (文字列)

メッセージがいつ再配信されたのかを判断するために使用する 1 つ以上の式を定義します。このプロパティは、​useSecureHash​ が ​false​ の場合にのみ設定できます。

Object Store (オブジェクトストア)

ObjectStore

各メッセージの再配信カウンターが保存されるオブジェクトストア。
### [](#repeatable-in-memory-stream)Repeatable In Memory Stream (反復可能なメモリ内ストリーム)
項目 型 説明 デフォルト値 必須

Initial Buffer Size (初期バッファサイズ)

Number (数値)

ストリームをコンシュームしてランダムにアクセスするために割り当てられるメモリ量。ストリームのデータ量がこのバッファサイズを超える場合は、​bufferSizeIncrement​ 属性に従って、​maxInMemorySize​ を上限としてバッファが拡張されます。

Buffer Size Increment (バッファサイズ増分)

Number (数値)

バッファサイズが初期サイズを超えた場合に、どれだけ拡張するか。値を 0 以下に設定すると、バッファが拡張されません。つまり、バッファがフルになると、​STREAM_MAXIMUM_SIZE_EXCEEDED​ エラーが発生します。

Max Buffer Size (最大バッファサイズ)

Number (数値)

使用するメモリの最大量。これを超えると、​STREAM_MAXIMUM_SIZE_EXCEEDED​ エラーが発生します。0 以下の値は無制限を意味します。

Buffer Unit (バッファ単位)

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

  • BYTE (バイト)

  • KB

  • MB

  • GB

これらのすべての属性の単位。
### [](#repeatable-file-store-stream)Repeatable File Store Stream (反復可能なファイルストアストリーム)
項目 型 説明 デフォルト値 必須

In Memory Size (メモリ内サイズ)

Number (数値)

データをメモリ内に保持するためにストリームで使用する最大メモリを定義します。これを超えると、コンテンツはディスクにバッファされます。

Buffer Unit (バッファ単位)

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

  • BYTE (バイト)

  • KB

  • MB

  • GB

maxInMemorySize​ で表される単位。
### [](#ExpirationPolicy)Expiration Policy (有効期限ポリシー)
項目 型 説明 デフォルト値 必須

Max Idle Time (最大アイドル時間)

Number (数値)

有効期限の対象とみなされるまで、動的設定インスタンスがアイドル状態を維持できる最大時間のスカラー時間値

Time Unit (時間単位)

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

  • NANOSECONDS

  • MICROSECONDS

  • MILLISECONDS

  • SECONDS

  • MINUTES

  • HOURS

  • DAYS

maxIdleTime 属性の時間単位
### [](#KafkaMessageMetadata)Kafka Message Metadata (Kafka メッセージのメタデータ)
項目 型 説明 デフォルト値 必須

オフセット

Number (数値)

Partition (パーティション)

Number (数値)

Serialized Key Size (シリアル化されたキーのサイズ)

Number (数値)

Serialized Value Size (シリアル化された値のサイズ)

Number (数値)

Timestamp (タイムスタンプ)

DateTime

Topic (トピック)

String (文字列)
## [](#関連情報)関連情報 - [Anypoint Connector の概要](https://docs.mulesoft.com/connectors/introduction/introduction-to-anypoint-connectors) - [MuleSoft ヘルプセンター](https://help.mulesoft.com)