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的集成

回答

相關問題