使用Java 8,Spark Streaming,Kafka, 一个演示项目,使用Spark Streaming来分析Twitter上的流行主题标签。 数据来自Twitter Streaming API源,并提供给Kafka。 消费者com.twitter.producer.service从Kafka接收数据,然后使用Spark Streaming在流中对其进行处理。 要求 Apache Maven 3.x JVM 8 Docker机器 注册了Twitter应用程序。 以下指南也可能会有所帮助: 快速入门指南 使用您的API密钥,客户端ID和秘密ID更改\producer\src\mai