付録F Kafka Connect 設定パラメーター

config.storage.topic

型：文字列
のインポート： high

コネクター設定が保存される Kafka トピックの名前。

group.id

型：文字列
のインポート： high

このワーカーが属する Connect クラスターグループを識別する一意の文字列。

key.converter

型：クラス
のインポート： high

offset.storage.topic

型：文字列
のインポート： high

コネクターオフセットが保存される Kafka トピックの名前。

status.storage.topic

型：文字列
のインポート： high

コネクターおよびタスクステータスが保存される Kafka トピックの名前。

value.converter

型：クラス
のインポート： high

bootstrap.servers

type: list
デフォルト： localhost:9092
Importance: high

Kafka クラスターへの最初の接続を確立するために使用するホストとポートのペアの一覧。クライアントは、ブートストラップ用に指定されたすべてのサーバーに関係なく、サーバーの完全なセットを検出するために使用される初期ホストにのみ影響します。このリストは host1:port1,host2:port2,… の形式にする必要があります。これらのサーバーは、クラスターの完全なメンバーシップを検出するために最初の接続に使用されるため（動的に変更される可能性がある）、この一覧にはサーバーの完全セットを含める必要はありません（サーバーがダウンした場合など）。

heartbeat.interval.ms

型： int
デフォルト： 3000（3 秒）
のインポート： high

Kafka のグループ管理機能の使用時に、ハートビートからグループコーディネーターにハートビートの間隔が想定される時間。ハートビートは、ワーカーのセッションがアクティブな状態を維持し、新規メンバーがグループに参加したり離れたりする際にリバランスを容易にするために使用されます。値は session.timeout.ms よりも低い値を設定する必要がありますが、通常はその値の 1/3 よりも高い値を設定する必要があります。通常のリバランスの予想される時間を制御するように調整することもできます。

rebalance.timeout.ms

型： int
デフォルト： 60000（1 分）
Importance: high

各ワーカーがグループに参加する最大許容期間を 1 度、リバランスを開始します。これは基本的に、保留中のデータをフラッシュしてオフセットをコミットするために必要な時間の制限です。タイムアウトを超えるとワーカーがグループから削除され、オフセットのコミットに失敗します。

session.timeout.ms

型： int
デフォルト： 10000（10 秒）
のインポート： high

ワーカーの失敗の検出に使用されるタイムアウト。ワーカーは定期的なハートビートを送信し、その liveness をブローカーに示します。このセッションタイムアウトの期限が切れる前にブローカーによってハートビートが受信されなかった場合、ブローカーはグループからワーカーを削除し、リバランスを開始します。この値は、group.min.session.timeout.ms および group.max.session.timeout.ms によってブローカー設定で設定されるため、許容範囲である必要があることに注意してください。

ssl.key.password