卡夫卡国营商店

Kafka State Store

如果有两个 Kafka 流从同一个 Kafka 主题消费,在容错情况下,如果一个 Kafka 流出现故障,那么 Kafka 状态存储将被复制到第二个 Kafka 流中。如果先回来,第二个 Kafka 流的状态存储会发生什么。

如果失败的实例恢复,将触发另一个重新平衡,一些任务将迁移到这个正在恢复的实例。但是,很难预测将迁移什么任务——商店可能会迁移回来。但是有许多运行时依赖关系会影响将要迁移的任务。在任何情况下,"old store" 很可能在失败后损坏,Streams 很可能将其清除(如果迁移回来则从头开始重新创建)。