我们偶尔会遇到副本负责人和其他ISR节点之间的高延迟,导致消费者收到以下错误:
org.apache.kafka.clients.consumer.RetriableCommitFailedException: Commit offsets failed with retriable exception. You should retry committing offsets. Caused by: org.apache.kafka.common.errors.TimeoutException: The request timed out.
我可以增加,offsets.commit.timeout.ms
但我不想,因为它可能会导致额外的副作用.但是从更广泛的角度来看,我不希望代理等待所有其他副本上的提交偏移同步,而是在本地提交并异步更新其余副本.通过代理配置,我找到了offsets.commit.required.acks
哪个看起来完全配置,但该文档也隐含地说:the default (-1) should not be overridden
.
为什么?我甚至尝试查看代理源代码,但发现其他信息很少.
知道为什么不推荐这个吗?是否有不同的方法来实现相同的结果?