4.2. 定義

bridge_version
任意

文字列

auto.offset.reset
任意

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

文字列

consumer.request.timeout.ms
任意

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

integer

enable.auto.commit
任意

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

boolean

fetch.min.bytes
任意

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

integer

format
任意

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

文字列

isolation.level
任意

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

文字列

name
任意

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

文字列

headers
任意

KafkaHeaderList

offset
任意

整数 (int64)

partition
任意

integer (int32)

topic
任意

string

base_uri
任意

このコンシューマーインスタンスに対する後続リクエストの URI 構築に使用されるベース URI。

文字列

instance_id
任意

グループ内のコンシューマーインスタンスの一意の ID。

文字列

error_code
任意

integer (int32)

message
任意

文字列

key
必須

文字列

value
必須

Base64 でエンコードされたバイナリー形式のヘッダー値
パターン: "^(?:[A-Za-z0-9+/]{4})*(?:[A-Za-z0-9+/]{2}==|[A-Za-z0-9+/]{3}=)?$"

文字列 (バイト)

offset
必須

整数 (int64)

partition
必須

integer (int32)

topic
必須

文字列

offsets
任意

< OffsetCommitSeek > 配列

offset
任意

整数 (int64)

partition
任意

integer (int32)

offsets
任意

< OffsetRecordSent > 配列

beginning_offset
任意

整数 (int64)

end_offset
任意

整数 (int64)

partition
任意

integer (int32)

topic
任意

文字列

leader
任意

integer (int32)

partition
任意

integer (int32)

replicas
任意

< Replica > 配列

partitions
任意

< Partition > 配列

headers
任意

KafkaHeaderList

partition
任意

integer (int32)

records
任意

< ProducerRecord > 配列

headers
任意

KafkaHeaderList

records
任意

< ProducerRecordToPartition > 配列

broker
任意

integer (int32)

in_sync
任意

boolean

leader
任意

boolean

partitions
任意

< AssignedTopicPartitions > 配列

topics
任意

Topics

configs
任意

トピックごとの設定のオーバーライド

< string, string > マップ

name
任意

トピックの名前

文字列

partitions
任意

< PartitionMetadata > 配列

topic_pattern
任意

複数のトピックを照合するための正規表現トピックパターン

文字列

topics
任意

< string > 配列