我想知道以下两种情况会发生什么。
情况1：使用DSL
stream
.groupbykey
.aggregate
.transform. <—- 1. Uncaught exception here
.to output <—- 2. Fail to Produce n/w issue
关于情况 1 的问题：在第 1 点。1.未捕获的异常或没有。2. Fail to Produce n/w 问题，服务重启时，聚合维护的状态存储会恢复到之前的状态吗？
情况2：
stream
.transform with state store and state store put
.transform another <— 1. Uncaught exception here
.to topic. <-- or 2. fail to produce due to n/w error
问题情况 2：放入状态存储的值是否会在 1 或 2 的异常中恢复？
简而言之。
Q1。就像一次一样，当我们不使用一次时，推送到状态存储的更改会在失败的情况下恢复吗？https://www.confluent.io/blog/enabling-exactly-once-kafka-streams/
Q2。非常愚蠢，但我不得不问，是否曾经适用于所有类型的 KStream 状态存储，一种是创建 DSL（聚合），另一种是我创建的用于 .transform 块？