作为 hazelcast-jet 源的 hazelcast 主题
hazelcast topic as a hazelcast-jet source
我正在努力加快使用 Hazelcast Jet 作为处理管道的速度，并开始深入研究 Sources 文档
https://jet-start.sh/docs/api/sources-sinks#sources
我很惊讶地看到 Hazelcast Topics and ReliableTopics aren't natively supported sources, however Kafka and JmsQueue are supported out of the box. I do see that a hazelcast reliabletopic is a supported sink...这让我怀疑我是否将主题误解为管道的有效来源。
我是不是误会了什么？
Hazelcast ITopic 是一种非分布式内存设施，不支持恰好一次处理。这些可能是 Hazelcast 迄今为止尚未提供 first-class 支持的部分原因。 Kafka 是持久性、分布式和容错设施的一个示例，这使其非常适合需要恰好一次一致性级别的架构。
另一方面，您可以使用 SourceBuilder 和 SinkBuilder 为其实现自己的连接器。 Here's 来自我们代码示例存储库的示例。
我正在努力加快使用 Hazelcast Jet 作为处理管道的速度，并开始深入研究 Sources 文档
https://jet-start.sh/docs/api/sources-sinks#sources
我很惊讶地看到 Hazelcast Topics and ReliableTopics aren't natively supported sources, however Kafka and JmsQueue are supported out of the box. I do see that a hazelcast reliabletopic is a supported sink...这让我怀疑我是否将主题误解为管道的有效来源。
我是不是误会了什么？
Hazelcast ITopic 是一种非分布式内存设施，不支持恰好一次处理。这些可能是 Hazelcast 迄今为止尚未提供 first-class 支持的部分原因。 Kafka 是持久性、分布式和容错设施的一个示例，这使其非常适合需要恰好一次一致性级别的架构。
另一方面，您可以使用 SourceBuilder 和 SinkBuilder 为其实现自己的连接器。 Here's 来自我们代码示例存储库的示例。