4.3. モデル

name

String

コンシューマーインスタンスの一意の名前。この名前は、コンシューマーグループの範囲内で一意です。名前は URL で使用されます。名前が指定されていない場合は、ランダムに生成された名前が割り当てられます。

format

String

コンシューマーに許可されるメッセージ形式。`binary` (デフォルト) または `json` にすることができます。メッセージは JSON 形式に変換されます。

auto.offset.reset

String

コンシューマーのオフセットの位置をリセットします。`latest` (デフォルト) に設定すると、メッセージが最新のオフセットから読み込まれます。`earliest` に設定すると、メッセージが最初のオフセットから読み込まれます。

fetch.min.bytes

Integer

コンシューマーが受信するデータの最小量をバイト単位で設定します。ブローカーは、送信するデータがこの量を超えるまで待機します。デフォルトは `1` バイトです。

consumer.request.timeout.ms

Integer

コンシューマーがリクエストのメッセージを待機する最大時間をミリ秒単位で設定します。レスポンスなしでタイムアウト期間に達すると、エラーが返されます。デフォルトは `30000` (30 秒) です。

enable.auto.commit

Boolean

`true` (デフォルト) に設定すると、メッセージのオフセットがコンシューマーに対して自動的にコミットされます。`false` に設定すると、メッセージのオフセットを手動でコミットする必要があります。

isolation.level

String

`read_uncommitted` (デフォルト) に設定すると、トランザクションの結果に関係なく、すべてのトランザクションレコードが取得されます。`read_committed` に設定すると、コミットされたトランザクションからのレコードが取得されます。