4.2. 定义

bridge_version
optional

字符串

auto.offset.reset
optional

重置消费者的偏移位置。如果设置为 latest （默认），则会从最新的偏移中读取消息。如果设置为 最早 的，则消息将从第一个偏移中读取。

字符串

consumer.request.timeout.ms
optional

设置消费者等待请求消息的最大时间（以毫秒为单位）。如果在没有响应的情况下达到超时时间，则返回错误。默认为 30000 (30 秒)。

整数

enable.auto.commit
optional

如果设置为 true （默认），则消息偏移会自动为消费者提交。如果设置为 false，则必须手动提交消息偏移。

布尔值

fetch.min.bytes
optional

设置要接收的消费者的最小数据量（以字节为单位）。代理会等待数据发送超过这个数量。默认为 1 字节。

整数

格式
可选

consumer 的允许消息格式，可以是 二进制 （默认）或 json。消息转换为 JSON 格式。

字符串

isolation.level
可选

如果设置为 read_uncommitted （默认），则检索所有事务记录，以免于任何事务结果。如果设置为 read_committed，则会检索来自已提交事务的记录。

字符串

name
可选

消费者实例的唯一名称。名称在消费者组范围内是唯一的。该名称在 URL 中使用。如果没有指定名称，则会分配一个随机生成的名称。

字符串

标头
可选

KafkaHeaderList

偏移
可选

integer (int64)

分区
可选

integer (int32)

主题
可选

字符串

base_uri
optional

用于构建针对此消费者实例的后续请求的 URI 的基础 URI。

字符串

instance_id
optional

组中消费者实例的唯一 ID。

字符串

error_code
optional

integer (int32)

message
可选

字符串

key
必需

字符串

必需 的值

标头值采用二进制格式, base64 编码的
Pattern : "^(?:[A-Za-z0-9+/]{4})*(?:[A-Za-z0-9+/]{2}==|[A-Za-z0-9+/]{3}=)?$"

字符串（字节）

需要 偏移

integer (int64)

需要 分区

integer (int32)

主题
必需

字符串

偏移
可选

< OffsetCommitSeek > array

偏移
可选

integer (int64)

分区
可选

integer (int32)

偏移
可选

< OffsetRecordSent > array

beginning_offset
optional

integer (int64)

end_offset
optional

integer (int64)

分区
可选

integer (int32)

主题
可选

字符串

领导
可选

integer (int32)

分区
可选

integer (int32)

replicas
可选

&lt ; replica > 数组

分区
可选

&lt ; partition > 数组

标头
可选

KafkaHeaderList

分区
可选

integer (int32)

记录
可选

< ProducerRecord > array

标头
可选

KafkaHeaderList

记录
可选

< ProducerRecordToPartition > array

代理
可选

integer (int32)

in_sync
optional

布尔值

领导
可选

布尔值

分区
可选

< AssignedTopicPartitions > 数组

主题
可选

topics

configs
可选

每个主题配置覆盖

< string, string > map

name
可选

主题的名称

字符串

分区
可选

< PartitionMetadata > 数组

topic_pattern
optional

用于匹配多个主题的 regex 主题模式

字符串

主题
可选

< string > 数字