我是新来的ApacheKafka和ApacheSpark。我想把Kafka和我的angularjs代码结合起来。基本上，我想确保，当用户点击任何链接或搜索我的网站上的任何东西时，这些搜索和点击应该作为一个事件触发，并将其发送到Kafka数据管道，以便使用分析。我的问题是如何将angular.js中的前端代码集成到ApacheKafka中？我是否可以使用kafka管道将搜索和单击流数据直接发送到apache spark，或者我是否需要将这些数据发送到kafka，apache spark将轮询到kafka服务器并批量接收数据？
1条答案
按热度按时间pkln4tw61#
我不认为有kafka客户端用于前端javascript。当数百万制作人（每个客户的浏览器）都在写同一个Kafka主题时，我真的无法想象稳定的设置。在angular中，您需要做的是调用服务器端函数来记录kafka中的事件。服务器端代码可以用多种语言编写，包括node.js的javascript。请查看Kafka文档中的可用客户
2019年更新：有几个项目为生产者和消费者接口实现RESToverHTTP（s）代理。例如kafka rest项目（源代码）。但我自己从没试过。