KSQL SERVER & Application Parallelism



假设我有一个带有5个分区的话题?如何确保仅使用一个KSQL Server,将创建5个应用程序以匹配最大并行性?

简而言之,KSQL Server可以运行多个应用程序(即KAFKA流应用程序(吗?如果是,我该如何说出要运行的查询实例数量?

是的,只要一个KSQL Server拥有足够的资源&容量。KSQL Server使用默认配置来运行查询。您需要确保为了获得最大的并行性,可以调整默认值。

例如,如果默认情况下num.stream.threads设置为3,并且要实现最大并行性,则可以更新以下的属性:

SET 'ksql.streams.num.stream.threads'='5';

有一些关于能力计划的好文档&配置:

https://docs.confluent.io/current/kerrent/ksql/docs/capacity-planning.html#ksql-capacity-planning

https://docs.confluent.io/current/kurrent/ksql/docs/installation/server-config/config/config-reference.html#ksql-configuration-parameter-parameter-reference

最新更新