Kubernetes 中具有持久状态存储的 KStream/KsqlDb 应用程序

Question

1. 这里有没有人有在 Kubernetes 环境中使用 Persistent State Store 部署 KStream/KsqlDb 应用程序而不失去自动可扩展性的经验？即自动创建状态存储卷和新容器的状态，并在容器消失后重新平衡，而不会丢失主题分区到数据卷映射。有可能吗？

2. 当持久状态存储消失（或被删除）时，KStream 会自动从更改日志主题恢复状态存储，还是我们必须手动将更改日志主题消费者上的消费者偏移量重置为最早？

Answer 1

1. 这很难实现。但是，对于这种情况，您可以使用备用任务来获得 HA。
2. 您无需执行任何操作。 Kafka Streams 将自动从变更日志中恢复状态。