我尝试在我的流应用程序中将 processing.guarantee 设置为 exact_once,但出现错误:NOT_ENOUGH_REPLICAS。我知道这将覆盖 acks=ALL。但是不明白为什么我会得到这个,而不管集群中是否有健康的经纪人。
更新:min insync replicas 设置为 2(代理级别设置),replication.factor 的默认值用于流中的内部主题为 1,我已将其更改为 3 修复了该问题。
我尝试在我的流应用程序中将 processing.guarantee 设置为 exact_once,但出现错误:NOT_ENOUGH_REPLICAS。我知道这将覆盖 acks=ALL。但是不明白为什么我会得到这个,而不管集群中是否有健康的经纪人。
更新:min insync replicas 设置为 2(代理级别设置),replication.factor 的默认值用于流中的内部主题为 1,我已将其更改为 3 修复了该问题。