【发布时间】:2020-05-14 01:38:31
【问题描述】:
我试图找到一些关于它的文档,当一些查询正在运行并且 KSQL-Server 重新启动时。会发生什么?
它的性能是否类似于 Kafka-Streams,因此不会提交消费者偏移量并保证至少一次?
我可以观察到查询存储在命令主题中,并且查询是在ksql-server重启时执行的
【问题讨论】:
标签: ksqldb
我试图找到一些关于它的文档,当一些查询正在运行并且 KSQL-Server 重新启动时。会发生什么?
它的性能是否类似于 Kafka-Streams,因此不会提交消费者偏移量并保证至少一次?
我可以观察到查询存储在命令主题中,并且查询是在ksql-server重启时执行的
【问题讨论】:
标签: ksqldb
我试图找到一些关于它的文档,当一些查询正在运行并且 KSQL-Server 重新启动时。会发生什么?
如果您只有一个 KSQL 服务器,那么停止该服务器当然会停止所有查询。一旦服务器再次运行,所有查询将从它们停止处理的点继续。没有数据丢失。
如果您有多个 KSQL 服务器正在运行,则停止其中一个(或部分)将导致其余服务器接管已停止服务器的任何查询处理任务。一旦停止的服务器重新启动,查询处理工作量将再次在所有服务器之间共享。
它的性能是否类似于 Kafka-Streams,因此不会提交消费者偏移量并保证至少一次?
是的。
但是(甚至更好):处理保证是至少一次还是完全一次完全取决于KSQL服务器的配置。它当然不取决于服务器是否或何时重新启动、崩溃等。
【讨论】: