apache-kafka-streams - 将 kafka 流状态存储移动到新目录 - 预期的行为是什么？

Question

我正在寻找将现有流应用程序的状态存储移动到新位置（通过定义“state.dir”）的预期行为。我找不到任何关于此的文档。

我认为它应该是透明的，并且应该与停止流应用程序时相同，手动删除存储然后再次启动应用程序。在这种情况下，从相应的内部变更日志主题中检索状态存储。但是，当我更改位置时（例如，从 /tmp/kafka-streams 更改为其他位置），我注意到状态存储被推送到下游（到主题 B）。这是预期的吗？我的流很简单：从主题 A -> 聚合（..） -> 到主题 B。

谢谢！

标签： apache-kafka-streams