Spark streaming消費Kafka的正確姿勢

Spark streaming消費Kafka的正確姿勢 前言 在遊戲項目中，需要對每天千萬級的遊戲評論信息進行詞頻統計，在生產者一端，我們將數據按照每天的拉取時間存入了Kafka當中，而在消費者一端，我們利用了spark streaming從kafka中不斷拉取數據進行詞頻統計。本文首先對spark streaming嵌入kafka的方式進行歸納總結，之後簡單闡述Spark streaming+k

>>阅读原文<<