当某些查询 运行 时重启 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服务器的配置。它当然不取决于服务器是否或何时重新启动、崩溃等
我试图找到一些关于它的文档,当一些查询 运行 并且 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服务器的配置。它当然不取决于服务器是否或何时重新启动、崩溃等