Language:
Format:

付録C コンシューマー設定パラメーター

key.deserializer

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

org.apache.kafka.common.serialization.Deserializer インターフェースを実装するキーの Deserializer クラス。

value.deserializer

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

org.apache.kafka.common.serialization.Deserializer インターフェースを実装する値の Deserializer クラス。

bootstrap.servers

type: list
デフォルト： ""
有効な値： non-null string
Importance: high

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

fetch.min.bytes

型： int
デフォルト： 1
有効な値： [0,…]
Importance: high

フェッチリクエストに対してサーバーが返すデータの最小量。十分なデータが十分にない場合、リクエストはその大量のデータが累積されるまで待機してからリクエストに応答します。デフォルトの 1 バイト設定は、データの 1 バイトが利用可能になり次第フェッチリクエストが即座に応答するか、またはデータに到達するのを待機するフェッチリクエストがタイムアウトすることを意味します。これを 1 よりも大きい値に設定すると、サーバーは大量のデータを累積するのを待機し、追加のレイテンシーのコストでサーバーのスループットを向上できます。

group.id

type: string
デフォルト： null
Importance: high

このコンシューマーが属するコンシューマーグループを識別する一意の文字列。このプロパティーは、コンシューマーが subscribe(topic) または Kafka ベースのオフセット管理システムを使用してグループ管理機能を使用する必要がある場合に必要です。

heartbeat.interval.ms

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

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

max.partition.fetch.bytes

型： int
デフォルト： 1048576(1 mebibyte)
有効な値： [0,…]
Importance: high

サーバーが返すパーティションごとのデータの最大量。レコードはコンシューマーによってバッチで取得されます。フェッチの最初の空でないパーティションで最初のレコードバッチがこの制限よりも大きい場合、バッチが返され、コンシューマーの進捗が保たれるようにします。ブローカーで許可される最大レコードバッチサイズは、message.max.bytes （ブローカー設定）または max.message.bytes （トピック設定）で定義されます。コンシューマー要求サイズを制限する場合は fetch.max.bytes を参照してください。

session.timeout.ms

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

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

ssl.key.password