当某些查询 运行 时重启 KSQL-Server

Restart KSQL-Server when some queries are running

我试图找到一些关于它的文档,当一些查询 运行 并且 KSQL-Server 重新启动时。会发生什么?

它的性能是否与 Kafka-Streams 类似,因此不提交消费者偏移量并保证至少一次?

我可以观察到命令主题中存储的查询,以及 ksql-server 重启时执行的查询

I try to find some document about it, that when some queries are running and KSQL-Server restarts. What will happened?

如果您只有一个 KSQL 服务器,那么停止该服务器当然会停止所有查询。一旦服务器再次 运行,所有查询将从它们停止处理的点继续。没有数据丢失。

如果您有多个 KSQL 服务器 运行,那么停止其中一个(或部分)服务器将导致其余服务器接管已停止服务器的所有查询处理任务。一旦停止的服务器重新启动,查询处理工作量将再次在所有服务器之间共享。

Does it perform similar to Kafka-Streams, so the consumer offset is not committed and at-least-once is guaranteed?

是的。

但是(甚至更好):处理保证是至少一次还是恰好一次完全取决于KSQL服务器的配置。它当然不取决于服务器是否或何时重新启动、崩溃等