当前位置:  开发笔记 > 运维 > 正文

Kafka异步提交偏移复制

如何解决《Kafka异步提交偏移复制》经验,为你挑选了0个好方法。

我们偶尔会遇到副本负责人和其他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.

为什么?我甚至尝试查看代理源代码,但发现其他信息很少.

知道为什么不推荐这个吗?是否有不同的方法来实现相同的结果?

推荐阅读
殉情放开那只小兔子
这个屌丝很懒,什么也没留下!
DevBox开发工具箱 | 专业的在线开发工具网站    京公网安备 11010802040832号  |  京ICP备19059560号-6
Copyright © 1998 - 2020 DevBox.CN. All Rights Reserved devBox.cn 开发工具箱 版权所有