当前位置: 首页 > 知识库问答 >
问题:

hazelcast jet是否从集群发送/接收数据

钱俊楚
2023-03-14

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

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

共有1个答案

秦德海
2023-03-14

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

 类似资料:
  • 有人能建议从节点集群收集指标的最佳模式吗(每个节点都是带有Java应用程序的Tomcat Docker容器)? 我们计划使用ELK堆栈(ElasticSearch、Logstash、Kibana)作为可视化工具,但我们的问题是如何将指标交付给Kibana? 我们使用DropWizard度量库,它提供每个实例的度量(量表、计时器、直方图)。 显然,应该收集每个实例的一些指标(例如,cpu、内存等..

  • 问题内容: 我知道这是经常问到的问题,但是我遍及整个Internet来查找我用来从AS3向PHP发送数据和从PHP接收数据的代码所犯的错误,反之亦然。你能找到错误吗?这是我的代码: AS3: [domain] /test.php中的PHP: 感谢您的回答。 问题答案: 您的AS代码似乎正确。因此问题可能出在PHP中。请首先使用以下PHP文件进行测试: 然后,这应该让您的电影跟踪。然后,您应该调试P

  • 实现蓝牙发送和接收数据的demo。文件包含两个工程,一个接收,一个发送。 [Code4App.com]

  • 因此,我正在用Java编写一个程序,在DatagramSocket和DataGramPacket的帮助下发送和接收数据。问题是,当我发送数据/接收数据时,数据在我发送的程序中也会有所不同,但只是在某些情况下,比如: 但有时会起作用,比如:

  • 问题内容: 我正在编写一个TCP服务器,可能需要15秒钟或更长时间才能开始生成对某些请求的响应主体。如果响应需要几秒钟才能完成,则某些客户端希望在其末端关闭连接。 由于生成响应非常占用CPU,因此我宁愿在客户端关闭连接时立即停止任务。目前,直到我发送第一个有效载荷并收到各种挂断错误后,我才发现这一点。 如何检测对等端已关闭连接而没有发送或接收任何数据?这意味着所有数据都保留在内核中,或者实际上没有