产品动态
公告
参数名称 | 默认值 | 说明 |
auto.offset.reset | latest | earliest：自动重置为最早偏移量。 latest：自动重置为最新偏移量。 |
enable.auto.commit | true | 如果为 true，消费者的偏移量将在后台定期提交。 |
auto.commit.interval.ms | 5000 （毫秒） | 如果 enable.auto.commit 设为 true，消费者偏移量自动提交的频率（毫秒）。 |
参数名称 | 默认值 | 说明 |
fetch.max.wait.ms | 500（毫秒） | 消费者在拉取消息时的最大等待时间 |
fetch.min.bytes | 1MB | 服务器为单次请求返回的最大数据量,如果没有足够的数据，则请求会等待。 |
fetch.max.bytes | 50MB | 服务器为单次请求返回的最大数据量。 过小（如1M）：每次拉取的数据量少，需要更多次请求才能获取足够数据，增加了服务端的会话次数。 过大（如50M+）：可能超过客户端处理能力，导致处理超时，消费积压、极端情况下会高频地向服务端请求同一批数据,导致您的计量计费增长。 |
request.timeout.ms | 30000 （毫秒） | 单次请求超时时间。与 fetch.max.bytes 配合使用。 过短（如5s）：可能导致批处理未达到 fetch.max.bytes 就返回，降低处理效率。 过长（如60s）：会增加消息处理延迟。 |
max.poll.records | 5000 (个) | 单次 poll() 调用返回的最大记录数。 |
session.timeout.ms | 10000（毫秒） | 消费者与 Kafka 服务器会话的超时时间（毫秒）。 |
heartbeat.interval.ms | 3000（毫秒） | 消费者发送心跳的间隔时间（毫秒）。 |
参数名称 | 默认值 | 说明 |
reconnect.backoff.ms | 50（毫秒） | 重新连接到服务器的初始退避时间（毫秒）。 |
retry.backoff.ms | 100（毫秒） | 重试失败请求前的等待时间（毫秒）。 |
max.poll.interval.ms | 120000（毫秒） | 两次 poll() 调用之间的最大允许间隔。如果超出此时间，消费者会被认为失败并触发重新平衡。 |
文档反馈