【发布时间】:2019-07-10 16:58:12
【问题描述】:
假设我有一个有 5 个分区的主题?如何确保仅使用一台 KSQL Server,将创建 5 个应用程序以匹配最大并行度?
简而言之,一个 KSQL Server 可以运行多个应用程序(即 Kafka 流应用程序)吗?如果是,我如何知道要运行的查询实例数?
【问题讨论】:
标签: ksqldb
假设我有一个有 5 个分区的主题?如何确保仅使用一台 KSQL Server,将创建 5 个应用程序以匹配最大并行度?
简而言之,一个 KSQL Server 可以运行多个应用程序(即 Kafka 流应用程序)吗?如果是,我如何知道要运行的查询实例数?
【问题讨论】:
标签: ksqldb
是的,一台 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
【讨论】: