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
optional

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

字符串

name
可选

使用者实例的唯一名称。该名称在消费者组的范围中是唯一的。该名称在 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})*(?:[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 > 数组

标头
可选

KafkaHeaderList

记录
可选

< ProducerRecordToPartition > array

broker
可选

integer (int32)

in_sync
optional

布尔值

领导
可选

布尔值

分区
可选

< AssignedTopicPartitions > 数组

topics
可选

主题

配置
可选

每个主题配置覆盖

< string, string > map

name
可选

主题的名称

字符串

分区
可选

< PartitionMetadata > array

topic_pattern
optional

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

字符串

topics
可选

< string > 数字