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

hazelcast主题作为hazelcast-Jet源

麻鸿熙
2023-03-14

我试图用Hazelcast Jet作为一个处理管道来获得更多的速度,并开始更多地挖掘源代码文档

我是不是误会什么了?

共有1个答案

谷梁博易
2023-03-14

Hazelcastitopic是一个非分布式内存工具,不支持精确一次处理。这些可能是Hazelcast到目前为止还没有提供一流支持的原因。Kafka是持久化、分布式和容错工具的一个例子,这使得它非常适合于需要精确一次一致性级别的体系结构。

另一方面,您可以使用SourceBuilderSinkBuilder为它实现自己的连接器。下面是我们的代码示例存储库中的一个示例。

 类似资料:
  • 我在我的应用程序中使用Hazelcast IMDG。 我听说Hazelcast Jet比Hazelcast IMDG提供更快的数据处理。 Hazelcast Jet提供了所有可用的功能Hazelcast IMDG?

  • Hazelcast Jet 是一个分布式计算平台,专为高性能流处理和快速批处理而构建。它在内存数据网格(IMDG)中嵌入Hazelcast,以提供轻量级的处理器包和可扩展的内存存储。 特性: 低延迟和分布式的通用数据处理框架,具有高吞吐量 高并行和分布式的数据流和批处理 分布式  java.util.stream API 支持 Hazelcast 数据结构,如 IMap 和 IList 连接器允许

  • 关于Hazelcast Jet我有以下问题 还有另一个应用程序(应用程序B,部署在集群中)实例化JetInstance并在每个节点上单独运行作业以处理记录。 目前,该作业从事件日记中读取数据并添加到IList中(reference-hazelcast-jet-0.5.1\code-samples\streaming\map-journal-source.java) 由于作业在多个节点上运行,事件日

  • 我很想知道Hazelcast Jet有多大的不同,它解决了什么问题?

  • 我对jet和hazelcast有一些问题,但出于逻辑目的,我的问题是,我有一个类,它将带来所有数据,当我们启动客户端时,我们得到一个队列和两个映射,但另一个映射尚未调用,当我启动hazelcast jet实例并在使用接收器时处理所有数据时,我放了以下内容: 但这是错误的。。。。我知道当你调用这个实例时,它就像hazelcast的getDataStructure,喷射它的内部hazelcast,我以

  • 我找不到任何从MultiMap构造源代码的可能性,为什么标准API中没有提供这样的源代码?https://docs.hazelcast.org/docs/jet/3.2/manual/#源和汇的概述