【问题标题】:Restart KSQL-Server when some queries are running运行某些查询时重新启动 KSQL-Server
【发布时间】:2020-05-14 01:38:31
【问题描述】:

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

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

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

【问题讨论】:

    标签: ksqldb


    【解决方案1】:

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

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

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

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

    是的。

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

    【讨论】:

    • 它是否也适用于从 CLI 或 KSQL REST API 创建的查询?
    • 是的。通过哪种方式创建查询并不重要。
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2014-11-13
    • 1970-01-01
    相关资源
    最近更新 更多