Kafka3ConnectionService¶
説明¶
Kafkaブローカーへの接続を提供・管理し、プロデューサまたはコンシューマ操作に使用します。
プロパティ¶
以下のリストでは、必要なプロパティをアスタリスク (*) で表示しています。その他のプロパティはオプションと見なされます。この表は、任意のデフォルト値と、そのプロパティが NiFi 式言語に対応しているかどうかも示します。
表示名 |
API 名前 |
デフォルト値 |
許容値 |
説明 |
|---|---|---|---|---|
SSL コンテキストサービス |
SSL コンテキストサービス |
Kafka ブローカーとの SSL 通信をサポートするサービス |
||
確認応答待ち時間 * |
ack.wait.time |
5秒 |
Kafkaにメッセージを送信した後、サービスがKafkaからの応答を待つ期間を示します。この期間内にKafkaがメッセージを受け取らなかった場合、サービスは例外をスローします。 |
|
ブートストラップ・サーバー * |
bootstrap.servers |
host:port の形式で Kafka Bootstrap Servers をカンマで区切ったリスト。Kafka bootstrap.servers プロパティに対応 |
||
クライアントのタイムアウト * |
default.api.timeout.ms |
60秒 |
Kafka クライアント操作のデフォルトのタイムアウト。Kafka default.api.timeout.msにマッピング。Kafka request.timeout.msプロパティは、構成されたタイムアウトの半分から派生する |
|
トランザクション分離レベル * |
isolation.level |
read_committed |
|
Kafkaと通信するとき、サービスがどのようにトランザクション分離レベルを扱うかを指定します。uncommitedオプションは、メッセージがKafkaに書き込まれるとすぐに受信されますが、プロデューサーがトランザクションをキャンセルした場合でもプルされることを意味します。commitedオプションは、プロデューサーのトランザクションがキャンセルされたメッセージを受信しないようにサービスを構成しますが、消費者はメッセージが利用可能になったときにプルするのではなく、プロデューサーがトランザクション全体を終了するまで待機する必要があるため、遅延が発生する可能性があります。Kafka isolation.levelプロパティに対応します。 |
最大メタデータ待ち時間 * |
max.block.ms |
5秒 |
パブリッシャーが 'send' 呼び出し中にメタデータを取得したり、 バッファがフラッシュされるのを待ってから、 'send' 呼び出しが失敗するまでの時間。Kafka max.block.ms プロパティに対応 |
|
マックス・ポール記録 * |
max.poll.records |
10000 |
Kafkaが1回のポーリングで返す記録の最大数。 |
|
SASL メカニズム * |
sasl.mechanism |
GSSAPI |
|
認証に使用する SASL メカニズム。Kafka クライアントの sasl.mechanism プロパティに対応 |
SASL パスワード * |
sasl.password |
PLAIN または SCRAM SASL メカニズムを使用する場合、構成されたユーザー名とともに提供されるパスワード。 |
||
SASL ユーザー名 * |
sasl.username |
PLAIN または SCRAM SASL メカニズムを使用する場合、構成されたパスワードとともに提供されるユーザー名。 |
||
セキュリティ・プロトコル * |
security.protocol |
PLAINTEXT |
|
ブローカーとの通信に使用されるセキュリティプロトコル。Kafka クライアントの security.protocol プロパティに対応します。 |
状態管理¶
このコンポーネントは状態を保存しません。
制限あり¶
このコンポーネントには制限はありません。
システムリソースに関する考察¶
このコンポーネントは、システムリソースを考慮したものではありません。