3.2.3. 消费者

auto.offset.reset
optional

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

字符串

consumer.request.timeout.ms
optional

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

整数

enable.auto.commit
optional

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

布尔值

fetch.min.bytes
可选

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

整数

格式
可选

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

字符串

isolation.level
optional

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

字符串

name
可选

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

字符串