问hazelcast主题作为hazelcast-jet源
EN

Stack Overflow用户

提问于 2020-12-07 22:05:28

回答 1查看 90关注 0票数 1

我正在尝试更快地使用Hazelcast Jet作为处理管道，并开始更深入地研究源代码文档

我非常惊讶地看到Hazelcast Topics和ReliableTopics不是原生支持的源码，但是Kafka和JmsQueue是开箱即用的。我确实看到了一种哈兹卡斯特的reliabletopic is a supported sink。这让我怀疑我是否误解了一个主题作为管道的有效来源。

我是不是误解了什么？

回答已采纳

发布于 2020-12-08 18:03:35

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

另一方面，您可以使用SourceBuilder和SinkBuilder来实现您自己的连接器。从我们的代码示例库中Here's一个示例。

票数 2

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/65183217

复制

相似问题

问hazelcast主题作为hazelcast-jet源EN