Kafka State Store

Question

如果有两个Kafka流从相同的Kafka主题消耗，那么在容错情况下，如果一个Kafka流发生故障，则Kafka状态存储将在第二个Kafka流中复制。如果第一次回到卡夫卡第二流的国家商店将会发生什么。

Answer 1

如果失败的实例回来，将会触发另一个重新平衡，并且一些任务将迁移到此恢复实例。很难预测哪些任务将被迁移 - 可能会发生，商店被迁移回来。但是有很多运行时依赖关系会影响哪些任务将被迁移。无论如何，故障发生后“旧店铺”很可能会损坏，Streams将最有可能将其清除（如果迁移回来，则从头开始重新创建）。