ksqldb - KSQL SERVER & 应用程序并行

Question

假设我有一个有 5 个分区的主题？我如何确保仅使用一个 KSQL Server，将创建 5 个应用程序以匹配最大并行度？

简而言之，一个 KSQL Server 可以运行多个应用程序（即 Kafka 流应用程序）吗？如果是，我如何告诉要运行的查询实例数？

标签： ksqldb

Answer 1

是的，一台 KSQL Server 可以运行多个应用程序，只要它有足够的资源和容量。KSQL 服务器使用默认配置来运行查询。您需要确保为了实现最大并行度，您可以调整默认值。

例如，如果num.stream.threads默认设置为 3，并且您想要实现最大并行度，您可以更新属性，如下所示：

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

有一些关于容量规划和配置的好文档：

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

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