需要在我的React-Native应用中使用Apache Kafka



我已经在项目中使用了apache kafka,并且需要将其集成在一个项目中,这也是项目的一部分。基本上,我的服务器是Kafka生产商,该应用需要收听主题并成为消费者。

首先,我尝试使用此NPM软件包。https://github.com/sohu-co/kafka-node。
但此软件包依赖于不属于React Native束的Nodej的核心模块。还有其他方法,所以我可以在React Native应用程序中使用Kafka进行通信?谢谢!

快速解决方案是将KAFKA群集放在简单的REST API后面。使用像Kafka-Rest这样的库可能是使用内置fetch功能连接您的React Andive应用程序的简便方法。您可以进一步迈出一步,并尝试将Kafka-Rest节点客户端集成到您的React Native应用程序中;粗略的回购概述不会导致任何核心节点依赖关系。

另一种允许"实时"更新的方法可能包括将KAFKA放在将KAFKA流转换为WebSocket连接的Web服务器后面。诸如Kafka-websocket之类的库允许客户端消费和生产,而Microsoft的Kafka-Proxy-WS等更简单的库仅允许使用消息。

值得注意的是,移动客户端并不总是与流数据合作,并且建议您在各种不确定的网络条件(延迟,删除信号等)上测试基于Websocket的实现。

尝试deepstreamio。

这是一个实时套接字服务器,与React-Native和Kafka都很好地集成。它可以使用Kafka作为消息代理,在分布式深层节点之间传达消息,并将消息推向其他订阅客户端。它们是开源的,因此您可以将其连接器配置为您的特定需求。

相关内容

  • 没有找到相关文章

最新更新