hazelcast-jet - Apache Pulsar 的 Hazelcast Jet 连接器作为源

Question

我找不到Hazlecast Jet. Apache Pulsar有人试过这个吗？如果我必须编写自定义stream连接器Pulsar作为 Jet 的来源，是否有任何方向、要点、来源和注意事项？

Answer 1

Apache Pulsar 的 Jet 连接器的初始版本最近在此处实现。它还没有经过广泛的测试。详情可以看一下说明连接器的充分和不足之处的设计文档，以及教程。如果对这些有什么困惑，你可以再问。

Answer 2

Hazelcast Jet 目前没有任何用于 Apache Pulsar 的连接器（4.0 版）。如果您想贡献一个，您可以查看Source Builder类及其在参考手册中的部分作为起点。

此外，请查看Hazelcast Jet 扩展模块存储库中各种连接器的现有实现，该存储库使用源构建器 API 并在那里贡献你的。