回答情况：
提问时间：
问题标签：
我正在尝试使用Jet聚合，源和宿都是Kafka主题，要求是从源中获取GPB (google proto buf)消息并发布GPB消息。问题是我可以发布Double，但不能发布GPB消息，它会给我编译错误。 Pipeline p = Pipeline.create(); .map(s->s.getValue() ).groupingKey(x->x.accoun
浏览 1修改于2019-02-08得票数 0
我正在尝试更快地使用Hazelcast Jet作为处理管道，并开始更深入地研究源代码文档 https://jet-start.sh/docs/api/sources-sinks#sources 我非常惊讶地看到Hazelcast Topics和ReliableTopics不是原生支持的源码，但是Kafka和JmsQueue是开箱即用的。我确实看到了一种哈兹卡斯特的reliabletopic is a supported sink。这让我怀疑我是否误解了一个主题作为管道的有效来源。 我是不是误解了什么？
浏览 20提问于2020-12-07得票数 1
回答已采纳
hazelcast-jet如何实现与早期通过在IMap中提交密钥上的EntryProcessors有很大不同的结果？
好奇地想知道。
浏览 2修改于2017-02-22得票数 1
我想对整个数据集进行简单的最大值运算。我从Kafka示例开始：p.drawFrom(KafkaSources.<Integer, User>kafka(brokerProperties(), TOPIC)) .rollingAggregate(minBy(comparingInt(user -> (Integer) user.get(2)))) .drainTo(Sinks.list("
浏览 1提问于2019-03-19得票数 0
我有一个现有的应用程序，它使用Hazelcast来跟踪集群成员关系和执行分布式任务。我在想，Jet对于在现有应用程序上添加分析可能很有用，我正在尝试找出如何在现有应用程序的基础上更好地分层Jet。我的第二个问题是，我看到了很多使用IMap和IList的例子，但我没有看到任何使用主题作为源代码的东西(我也不认为这是源代码构建器的一个选项)。我使用Jet的最初想法是从现有代码向主题发出事件(
浏览 15提问于2020-05-27得票数 1
回答已采纳
我正在运行Hazelcast-Jet的3节点嵌入式集群，控制台中经常出现以下错误。可能的原因是什么？
浏览 14修改于2019-05-14得票数 0
我正在跟踪，以尝试如何通过直接从IMap中查找来丰富无界流。我有两张地图：
public class Product implements DataSerializable { String sellerId;...
public class Seller i
浏览 6提问于2019-10-07得票数 1
回答已采纳
我在instructions here之后在亚马逊网络服务的ec2上建立了一个Hazelcast-jet集群。我利用了hazelcast-aws模型，这样节点就可以自动发现彼此。
浏览 12提问于2019-09-27得票数 1
回答已采纳
hazelcast-jet / hazelcast是否在RAM有限的情况下提供了这样的外部排序功能？
浏览 1修改于2020-08-10得票数 3
因此，我选择了hazelcast-jet，这是一种性能优异的内存处理模型.在这里，我有几个关于模型的问题：
将hazelcast-jet部署到多个ec2实例的最佳方法是什么？
浏览 2修改于2019-09-25得票数 2
回答已采纳
我一直在浏览hazelcast-jet文档，寻找一些外部进程异步提供的源的引用--在我的例子中是http post。
我确实查看了，因为这似乎是最接近的，但我不知道新到达的事件如何触发任何事情。
浏览 3提问于2018-09-24得票数 1
我想在我的应用程序中使用hazelcast-jet，因为在我的例子中，kafka分区的数量是有限的。
浏览 6修改于2020-11-22得票数 2
回答已采纳
我在Spring Boot v.2.0.3.RELEASE上运行hazelcast-jet-spring artifact (不是hazelcast-jet) v.0.6.1，并得到以下错误：
Caused
浏览 9提问于2018-07-24得票数 0
回答已采纳
</dependency> <groupId>com.hazelcast.jet</groupId>
<artifactId>hazelcast-jet
浏览 18修改于2022-06-24得票数 0
我正试图在一个分布式系统上运行一个Hazelcast-jet 。我的目标是在分布式系统上运行代码，利用多台机器的处理能力。我有两台笔记本电脑通过局域网连接。
浏览 7提问于2019-11-09得票数 1
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号