KSQL :在KSQL服务器重新启动后丢失Kstream数据

Question

我使用查询"Create base_stream with“(kafka-topic ="myTopic"，format="avro")创建了一个流，这个主题拥有超过800 of的数据并在不断增长。

问题：

1. 是否复制了新流中底层主题中的数据？或者是相同的数据?当KSQL服务器重新启动时，
2. base_stream丢失了其数据。有任何方法来持久化这些数据吗？因为，如果每次KSQL server重新启动时都必须重新同步/重新创建base_stream，这可能需要许多小时！
3. 我知道可以从"base_stream“创建持久流，但是，我们将在2 streams

中复制数据。

感谢您的回复，谢谢！

Answer 1

我知道可以从"base_stream“创建持久流，但是，我们将在两个流中复制数据

仓库很便宜。我见过很多结核病大的话题。如果您能够随着时间的推移发出聚合窗口以减少大小，则可以启用有关该主题的压缩策略和保留策略

当KSQL服务器重新启动时，

base_stream丢失了它的数据。有任何方法来持久化这些数据吗？

您在现有主题的基础上创建了流。没有一个流认为需要恢复或丢失的真实数据，这回答了问题1