KafkaStreams处理保证exact_once和exact_once_beta的区别

Question

问题很简单，Kafka Streams 中这两种保证有什么区别？

processing.guarantee:exactly_once/exactly_once_beta

文档说

使用“exactly_once”需要代理版本 0.11.0 或更高版本，而使用“exactly_once_beta”需要代理版本 2.5 或更高版本。请注意，如果启用了一次性处理，则参数 commit.interval.ms 的默认值将更改为 100 毫秒。

但没有什么区别。

Answer 1

当您配置exactly_once_beta 时，事务处理将使用新的实现来完成，随着生产者数量的增加启用better performance。

但是请注意，如果您在早期 Kafka 版本中使用了 exact_once，则需要 two-step migration。