查询如何在 Ksql Server 上分布

Question

考虑到扩展，我想知道查询是如何在 KSQL 服务器之间分布的？

1 - 假设你有 cli 或 confluent 控制中心，cli 是连接到所有服务器还是其中之一？它可以将查询发送到多个 KSQL SERVER，例如那些具有相同 id（即 Pool id）的人？

2 - 我们可以在多个 KSQL SERVER 上运行同一查询的多个实例吗？如果是的话，它是如何工作的，例如关于消费者组或分区？

3 - 我们可以在同一个 KSQL SERVER 上运行同一查询的多个实例吗？

Answer 1

@Robin Moffatt 如果我错了请指正：

1 - 假设你有 cli 或 confluent 控制中心，cli 连接到所有服务器或其中之一？它可以将查询发送到 多个 KSQL SERVER 例如那些具有相同 id（即 Pool id）的人？

好像没有。一台连接一台KSQL SERVER，命令会转发到Command Topic，所有KSQL SERVER都会显示为红色。

2 - 我们可以运行同一查询的多个实例吗 多个 KSQL SERVER ？如果是的话，它是如何工作的，例如关于 消费者组或分区？

是的，查询被发送到一个 KSQL SERVER，后者将其转发到命令主题，其他 KSQL SERVER 从中获取并运行。我怀疑必须进行协调，以避免过度配置查询。否则，如果每个服务器都自动运行该命令，我们可能会以比分区更多的拓扑实例结束。你能澄清最后一部分吗？

3 - 我们可以在同一查询上运行多个实例吗？ 同一个 KSQL SERVER？

不，我们不能。但是，每个服务器只有一个查询实例，该查询可以设置为具有一定数量的线程。每个线程都是“应用程序的某种独立实例”，或者 Kafka 行话中的一个并行单元。事实上，我会更具体地说，每个线程都是拓扑的独立实例。