趋势图 构建一个java Tweet Collector以使用Twitter Streaming API收集实时Tweet 将收集的推文推送到Kafka集群 利用Apache Flink流处理(解析,过滤和转换)tweet 将处理过的推文接收到Elasticsearch以获取数据持久性和索引 开发SpringBoot RESTful API server以查询来自Elasticsearch的推文 使用Frontend Angular Web应用程序可视化实时推文趋势 使用Kibana显示地理推文热图 创建Docker映像并将microservices部署到Kubernetes集群 项目结构