4.2. 定义

bridge_version
optional

字符串

auto.offset.reset
optional

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

字符串

consumer.request.timeout.ms
optional

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

整数

enable.auto.commit
optional

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

布尔值

fetch.min.bytes
optional

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

整数

格式
可选

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

字符串

isolation.level
optional

如果设置为 read_uncommitted （默认），则检索所有事务记录，并表示任何事务结果的发送。如果设置为 read_committed，则检索来自提交的事务中的记录。

字符串

name
可选

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

字符串

标头
可选

KafkaHeaderList

key
可选

字符串

偏移
可选

integer (int64)

分区
可选

integer (int32)

Topic
可选

字符串

value
可选

字符串

base_uri
optional

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

字符串

instance_id
optional

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

字符串

error_code
optional

integer (int32)

message
可选

字符串

key
必需

字符串

需要
的值

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

字符串（字节）

需要 偏移

integer (int64)

分区
是必需的

integer (int32)

主题
必需

字符串

偏移
可选

< OffsetCommitSeek > 数组

偏移
可选

integer (int64)

分区
可选

integer (int32)

偏移
可选

< OffsetRecordSent > 数组

beginning_offset
optional

integer (int64)

end_offset
optional

integer (int64)

分区
可选

integer (int32)

Topic
可选

字符串

领导
可选

integer (int32)

分区
可选

integer (int32)

replicas
可选

&lt ; replica > 数组

分区
可选

&lt ; partition > 数组

标头
可选

KafkaHeaderList

分区
可选

integer (int32)

记录
可选

< ProducerRecord > 数组

记录
可选

< ProducerRecordToPartition > array

broker
可选

integer (int32)

in_sync
optional

布尔值

领导
可选

布尔值

分区
可选

< AssignedTopicPartitions > 数组

topics
可选

主题

配置
可选

每个主题配置覆盖

< string, string > map

name
可选

主题的名称

字符串

分区
可选

< PartitionMetadata > array

topic_pattern
optional

匹配多个主题的正则表达式主题模式

字符串

topics
可选

< string > 数字