angular.js与apache kafka的集成

我是新来的apache kafka和apache的火花。我想将kafka与我的angularjs代码结合起来。基本上我想确保，当用户点击任何链接或在我的网站上搜索任何内容时，那些搜索和点击应作为事件触发，并将其发送到kafka数据管道以使用分析。我的问题是如何将angular.js中的前端代码集成到apache kafka中？我可以使用kafka管道将搜索和点击流数据直接发送到apache spark，还是需要将这些数据发送到kafka，并且apache spark会对kafka服务器进行轮询并批量接收数据？angular.js与apache kafka的集成

来源

2016-11-19 Vikas Pandey

我不认为（只是无法一目了然地看到）有前端JavaScript的Kafka客户端。当数百万的制作者（每个客户的浏览器）写入相同的Kafka话题时，我实际上无法想象稳定的设置。 Angular需要做的是调用你的服务器端函数来记录你在卡夫卡的事件。服务器端代码可以用一堆语言编写，包括用于node.js的JavaScript。请看看Kafka Documentation

来源

2016-11-19 02:01:35

可用的客户端我看到，Kafka节点为node.js，但是我正在寻找angular.js的客户端插件。由于kafka是可扩展的，所以我想确保每个客户端（即生产者）连接到同一主题。 –

卡夫卡为可持续数据流输入主题而建立，而不是为数百万的开/关连接建立，客户端采购场景将会是什么。你可以准备很简单的可行性测试。结果会很有趣。 –

所以，基本上没有办法，我们可以使用angular.js来实现kafka客户端。我们需要将REST调用从angular发送到node.js中的路由处理程序，而这些处理程序又将作为kafka生产者。它会使用kafka数据管道将数据发送到apache spark，这将是使用者还是将使用kafka数据管道将数据发送到apache kafka服务器？ –

angular.js与apache kafka的集成

回答

相关问题