Apache Kafka Connector 4.9 リファレンス - Mule 4

Array of String (文字列の配列)

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

x

String (文字列)

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

Number

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

1

Number

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

60

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

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

SECONDS

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

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

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

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

READ_UNCOMMITTED

Boolean

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

true

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

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

LATEST

Number

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

100

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

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

MILLISECONDS

Boolean

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

true

Number

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

64

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

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

KB

Number

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

128

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

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

KB

Number

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

30

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

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

SECONDS

Number

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

500

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

クライアントによる DNS ルックアップの使用方法を制御します。​USE_ALL_DNS_IPS​ に設定する場合、ルックアップでホスト名の複数の IP アドレスが返されると、接続に失敗するまで接続が試行されます。ブートストラップサーバーとアドバタイズサーバーの両方に適用されます。値が ​RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY​ の場合、各エントリが解決されて、正規名のリストに展開されます。

USE_ALL_DNS_IPS

Number

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

3

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

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

SECONDS

Number

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

10

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

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

SECONDS

Number

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

540

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

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

SECONDS

Object (オブジェクト)

Kafka 接続のカスタマイズに使用する追加のプロパティ。

次に例を示します。

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​) を自動的に使用します。

String (文字列)

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

Array of String (文字列の配列)

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

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

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

Number

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

1

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

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

BYTE

Number

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

1

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

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

MB

Number

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

1

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

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

MB

Number

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

500

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

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

MILLISECONDS

Reconnection (再接続)

コネクタ操作で外部サーバーへの接続に失敗した場合に使用する再接続戦略を設定します。

Array of String (文字列の配列)

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

x

String (文字列)

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

Number

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

1

Number

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

60

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

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

SECONDS

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

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

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

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

READ_UNCOMMITTED

Boolean

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

true

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

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

LATEST

Number

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

100

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

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

MILLISECONDS

Boolean

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

true

Number

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

64

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

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

KB

Number

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

128

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

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

KB

Number

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

30

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

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

SECONDS

Number

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

500

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

クライアントによる DNS ルックアップの使用方法を制御します。​USE_ALL_DNS_IPS​ に設定する場合、ルックアップでホスト名の複数の IP アドレスが返されると、接続に失敗するまで接続が試行されます。ブートストラップサーバーとアドバタイズサーバーの両方に適用されます。値が ​RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY​ の場合、各エントリが解決されて、正規名のリストに展開されます。

USE_ALL_DNS_IPS

Number

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

3

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

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

SECONDS

Number

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

10

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

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

SECONDS

Number

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

540

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

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

SECONDS

Object (オブジェクト)

Kafka 接続のカスタマイズに使用する追加のプロパティ。

次に例を示します。

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​) を自動的に使用します。

String (文字列)

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

Array of String (文字列の配列)

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

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

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

Number

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

1

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

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

BYTE

Number

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

1

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

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

MB

Number

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

1

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

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

MB

Number

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

500

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

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

MILLISECONDS

String (文字列)

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

x

String (文字列)

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

x

String (文字列)

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

Boolean

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

false

String (文字列)

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

Boolean

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

false

String (文字列)

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

Boolean

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

false

Reconnection (再接続)

コネクタ操作で外部サーバーへの接続に失敗した場合に使用する再接続戦略を設定します。

Array of String (文字列の配列)

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

x

String (文字列)

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

String (文字列)

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

Number

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

1

Number

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

60

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

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

SECONDS

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

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

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

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

READ_UNCOMMITTED

Boolean

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

true

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

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

LATEST

Number

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

100

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

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

MILLISECONDS

Boolean

コンシュームされるレコードの CRC32 を自動的にチェックします。これにより、送信中またはディスク上でのメッセージの破損が発生しなくなります。このチェックにより、オーバーヘッドが増えるため、極端なパフォーマンスを求める場合はこれを無効にすることができます。

true

Number

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

64

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

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

KB

Number

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

128

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

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

KB

Number

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

30

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

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

SECONDS

Number

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

500

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

クライアントによる DNS ルックアップの使用方法を制御します。use_all_dns_ips に設定する場合、ルックアップでホスト名の複数の IP アドレスが返されると、接続に失敗するまですべての IP アドレスの接続が試行されます。ブートストラップサーバーとアドバタイズサーバーの両方に適用されます。値が resolve_canonical_bootstrap_servers_only の場合、各エントリが解決されて、正規名のリストに展開されます。

USE_ALL_DNS_IPS

Number

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

3

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

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

SECONDS

Number

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

10

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

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

SECONDS

Number

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

540

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

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

SECONDS

Object (オブジェクト)

Kafka 接続のカスタマイズに使用する追加のプロパティ。

次に例を示します。

TLS

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

Array of String (文字列の配列)

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

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

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

Number

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

1

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

BYTE

Number

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

1

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

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

MB

Number

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

1

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

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

MB

Number

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

500

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

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

MILLISECONDS

String (文字列)

JAAS 設定内で OAuth クライアント ID を定義するために使用する設定キーを指定します。

clientId

String (文字列)

OAuth クライアントに割り当てられた一意の識別子を参照するクライアント ID の値。セキュアな認証と認証プロセスが促進されます。

x

String (文字列)

JAAS 設定内で OAuth クライアントの秘密を定義するために使用する設定キーを指定します。

clientSecret

String (文字列)

OAuth クライアントに割り当てられた機密の認証ログイン情報を参照するクライアントシークレットの値。

x

String (文字列)

JAAS 設定内で OAuth トークンエンドポイントを定義するために使用する設定キーを指定します。

sasl.oauthbearer.token.endpoint.url

String (文字列)

クライアントが認証サーバーにアクセストークンを要求できる URL を記述します。

x

String (文字列)

JAAS 設定内で OAuth スコープを定義するために使用する設定キーを指定します。

scope

String (文字列)

認証サーバーによってクライアントアプリケーションに付与される特定の権限とアクセス権を定義します。

String (文字列)

JAAS 設定内で OAuth 対象者を定義するために使用する設定キーを指定します。

audience

String (文字列)

アクセストークンの 1 人以上の対象者のカンマ区切りリスト。

Number

アクセストークンが有効のままである最大期間 (秒) を設定します。

String (文字列)

認証済みユーザーに関連付けられている一意の識別子。多くの場合、認証決定やリソースアクセスで使用されます。

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

クライアントログイン情報を基本認証ヘッダーまたは認証要求の本文のどちらに含めるかを定義します。

BASIC_AUTHENTICATION_HEADER

Boolean

OAuth 2.0 ベアラートークンを使用して Kafka クライアントで接続を確立するにはこのログインモジュールが正常に認証される必要があるかどうかを示します。

true

Boolean

「Accept-application/json」ヘッダーを認証要求に含めるかどうか。

true

Object

カスタムブローカー OAuth 実装の拡張機能が含まれるキー-値ペアのマッピングを表します。[OAuth Extensions (OAuth 拡張機能)] 項目にキーを指定する場合は、入力に英字のみが含まれ、1 文字以上であることを確認します。[OAuth Extensions (OAuth 拡張機能)] 項目の値を指定する場合は、入力に印刷可能な ASCII 文字または空白 (スペース、タブ、復帰、改行を含む) のみが含まれ、値が 1 文字以上であることを確認します。

Number

ログイン情報の有効期間の特定の部分が経過してログイン情報の更新を試行するまでログイン更新スレッドが待機する期間。有効な値は (0.5) 50% ～ (1.0) 100%、指定しない場合のデフォルトは (0.8) 80% です。

0.8

Number

ログイン情報の有効期間を基準としてログイン更新スレッドのスリープ時間に追加する相対的な最大ランダムジッターは (0) 0% ～ (0.25) 25%、指定しない場合のデフォルトは (0.05) 5% です。

0.05

Number

ログイン情報を更新するまでログイン更新スレッドが待機する、目的の最小時間 (秒)。有効な値は 0 ～ 900 (15 分) です。

60

Number

ログイン情報を更新するときに維持されるログイン情報有効期限までのバッファ時間 (秒)。有効な値は 0 ～ 3600 (1 時間) です。値を指定しない場合、デフォルト値の 300 (5 分) が使用されます。

300

Boolean (ブール)

永続接続を使用するかどうかを示します。

Mule は永続接続を使用します。

Mule は最初の要求が完了すると接続を閉じます。

true

Number (数値)

バックエンドに対して開く接続の最大数。HTTP 要求は、複数の接続を介して並行して送信されます。この値の設定が高すぎると、レイテンシーに影響し、スループットを高めることなく追加リソースがコンシュームされる可能性があります。デフォルトでは、接続数は無制限です。

-1

Number (数値)

接続が終了するまでのアイドル状態を維持できるミリ秒。この属性の値は、永続接続が有効になっている場合にのみ使用されます。

30000

Boolean (ブール)

受信応答をストリーミングする必要があるかどうか。つまり、すべてのヘッダーが解析されたらすぐに処理を続行し、本文は到着するとストリーミングされます。設定されたバッファサイズによっては、メモリに収まらず、容量が空くまで処理が停止する可能性があるため、有効になっている場合は徐々に応答を読み取る必要があります。

false

Number (数値)

HTTP 応答が保存されるバッファのサイズ (バイト)。デフォルトでは、容量は制限されません。

-1

TCP クライアントソケットのパラメーター

TCP クライアントソケット接続の設定可能なプロパティをカプセル化します。

Proxy Config Params (プロキシ設定パラメーター)

アウトバウンド接続のプロキシを設定します。

Boolean

リダイレクトをフォローするかどうかを示します。

false

Number (数値)

要求要素が HTTP 応答を待機中のフローの実行をブロックする最大時間。

60000

Reconnection (再接続)

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

Array of String (文字列の配列)

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

x

String (文字列)

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

Number

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

1

Number

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

60

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

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

SECONDS

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

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

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

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

READ_UNCOMMITTED

Boolean

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

true

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

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

LATEST

Number

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

100

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

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

MILLISECONDS

Boolean

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

true

Number

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

64

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

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

KB

Number

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

128

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

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

KB

Number

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

30

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

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

SECONDS

Number

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

500

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

クライアントによる DNS ルックアップの使用方法を制御します。​USE_ALL_DNS_IPS​ に設定する場合、ルックアップでホスト名の複数の IP アドレスが返されると、接続に失敗するまで接続が試行されます。ブートストラップサーバーとアドバタイズサーバーの両方に適用されます。値が ​RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY​ の場合、各エントリが解決されて、正規名のリストに展開されます。

USE_ALL_DNS_IPS

Number

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

3

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

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

SECONDS

Number

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

10

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

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

SECONDS

Number

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

540

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

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

SECONDS

Object (オブジェクト)

Kafka 接続のカスタマイズに使用する追加のプロパティ。

次に例を示します。

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​) を自動的に使用します。

String (文字列)

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

Array of String (文字列の配列)

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

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

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

Number

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

1

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

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

BYTE

Number

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

1

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

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

MB

Number

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

1

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

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

MB

Number

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

500

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

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

MILLISECONDS

String (文字列)

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

x

String (文字列)

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

x

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

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

x

Reconnection (再接続)

コネクタ操作で外部サーバーへの接続に失敗した場合に使用する再接続戦略を設定します。

Array of String (文字列の配列)

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

x

String (文字列)

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

Number

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

1

Number

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

60

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

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

SECONDS

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

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

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

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

READ_UNCOMMITTED

Boolean

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

true

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

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

LATEST

Number

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

100

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

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

MILLISECONDS

Boolean

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

true

Number

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

64

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

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

KB

Number

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

128

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

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

KB

Number

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

30

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

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

SECONDS

Number

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

500

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

クライアントによる DNS ルックアップの使用方法を制御します。​USE_ALL_DNS_IPS​ に設定する場合、ルックアップでホスト名の複数の IP アドレスが返されると、接続に失敗するまで接続が試行されます。ブートストラップサーバーとアドバタイズサーバーの両方に適用されます。値が ​RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY​ の場合、各エントリが解決されて、正規名のリストに展開されます。

USE_ALL_DNS_IPS

Number

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

3

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

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

SECONDS

Number

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

10

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

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

SECONDS

Number

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

540

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

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

SECONDS

Object (オブジェクト)

Kafka 接続のカスタマイズに使用する追加のプロパティ。

次に例を示します。

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​) を自動的に使用します。

String (文字列)

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

Array of String (文字列の配列)

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

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

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

Number

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

1

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

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

BYTE

Number

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

1

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

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

MB

Number

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

1

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

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

MB

Number

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

500

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

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

MILLISECONDS

String (文字列)

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

x

String (文字列)

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

x

Reconnection (再接続)

コネクタ操作で外部サーバーへの接続に失敗した場合に使用する再接続戦略を設定します。

Array of String (文字列の配列)

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

x

String (文字列)

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

Number

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

1

Number

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

60

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

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

SECONDS

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

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

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

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

READ_UNCOMMITTED

Boolean

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

true

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

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

LATEST

Number

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

100

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

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

MILLISECONDS

Boolean

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

true

Number

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

64

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

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

KB

Number

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

128

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

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

KB

Number

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

30

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

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

SECONDS

Number

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

500

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

クライアントによる DNS ルックアップの使用方法を制御します。​USE_ALL_DNS_IPS​ に設定する場合、ルックアップでホスト名の複数の IP アドレスが返されると、接続に失敗するまで接続が試行されます。ブートストラップサーバーとアドバタイズサーバーの両方に適用されます。値が ​RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY​ の場合、各エントリが解決されて、正規名のリストに展開されます。

USE_ALL_DNS_IPS

Number

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

3

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

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

SECONDS

Number

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

10

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

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

SECONDS

Number

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

540

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

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

SECONDS

Object (オブジェクト)

Kafka 接続のカスタマイズに使用する追加のプロパティ。

次に例を示します。

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​) を自動的に使用します。

String (文字列)

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

Array of String (文字列の配列)

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

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

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

Number

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

1

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

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

BYTE

Number

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

1

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

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

MB

Number

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

1

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

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

MB

Number

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

500

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

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

MILLISECONDS

String (文字列)

トークンの ID。

x

String (文字列)

トークン HAMC。

x

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

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

x

Reconnection (再接続)

コネクタ操作で外部サーバーへの接続に失敗した場合に使用する再接続戦略を設定します。

Array of String (文字列の配列)

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

x

Number

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

16

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

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

KB

Number

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

1

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

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

KB

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

クライアントによる DNS ルックアップの使用方法を制御します。​USE_ALL_DNS_IPS​ に設定する場合、ルックアップでホスト名の複数の IP アドレスが返されると、接続に失敗するまで接続が試行されます。ブートストラップサーバーとアドバタイズサーバーの両方に適用されます。値が ​RESOLVE_CANONICAL_BOOTSTRAP_SERVERS_ONLY​ の場合、各エントリが解決されて、正規名のリストに展開されます。

USE_ALL_DNS_IPS

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

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

NONE

Number

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

540

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

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

SECONDS

Number

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

120

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

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

SECONDS

Boolean

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

false

Number

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

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

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

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

0

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

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

SECONDS

Number

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

60

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

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

SECONDS

Number

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

5

Number

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

1

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