0

我们在服务器上托管了一个 Hazelcast 集群,并且在同一区域的不同服务器上的不同应用程序使用 Hazelcast Jet 客户端实例使用管道聚合来自 Kafka 源的数据。

在此设置中,Jet 客户端实例是否发送它从 Kafka 源 Hazelcast 集群接收到的数据,这将涉及大量 IO,或者当我们创建管道时,Hazelcast 集群本身会创建与 Kafka 的连接,并且此连接来自 Jet 集群而不是来自客户端应用程序?

4

1 回答 1

0

@Abhishek,您需要在某个地方有一个 Jet 集群。作业本身在 Jet 集群上运行。如果您有 Kafka 作为源,您的应用程序会将作业提交到 Jet 集群,Jet 集群将连接到数据。如果您的接收器是同一个 Jet 集群上的 Hazelcast 地图,它将是本地写入,如果它是单独的 Hazelcast 集群,那么您需要使用Sinks.remoteMap配置客户端来连接到远程 Hazelcast 集群。

于 2019-01-24T19:03:02.810 回答