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

Question

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

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

Answer 1

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