在Kafka Stream中只处理一次配置是否保证只读取提交的读取？

Question

有一系列关于Kafka交易和一次性交付的优秀文章
在其中一篇文章中，作者谈到了消费者：

因此，在消费者端，您有两个选项来读取事务性消息，通过“isolation.level”消费者配置来表示：

read_committed：除了读取不属于事务的消息外，还可以在事务提交后读取属于事务的消息。

read_uncommitted（读取未提交）：按偏移顺序读取所有消息，而无需等待事务提交。此选项类似于Kafka消费者的当前语义。

也就是说，正常的消费者应用程序必须指定read_committed如果只希望从主题读取提交写入。

然而，关于Kafka流：

要使Streams应用程序只使用一次语义学，只需将此配置设置为“processing.guarantee=exactly_once”。这会导致所有处理只发生一次；这包括使处理和写回Kafka的处理作业创建的所有物化状态都只发生一次。

没有明确说明KStream中的读取。当配置了之后，KStream是否只读取提交的消息？




Answer 1

是的，KStream只会读取已提交的消息，它在留档中没有明确说明，但在StreamsConfig JavaDoc中您会找到以下信息：

如果processing.guarantee设置为exactly_once，则Kafka Streams不允许用户覆盖以下属性（括号中显示的Streams设置）：isolation.level（read_committed）-消费者将始终只读取提交的数据enable.idempotence（true）-生产者将始终启用幂等max.in.flight.requests.per.connection（5）-生产者将始终为每个连接提供一个动态请求