Spark Streaming+kafka+spring boot+elasticsearch实时项目(canal)_sparkelasticsearch kafka git-CSDN博客

网站介绍:文章浏览阅读1.5k次。在本次实验中,利用spark、elasticsearch、kafka等相关框架搭建一个实时计算系统。具体流程如下图所示,用户访问对应服务,由nginx服务器进行负载均衡访问具体的主机上的服务,访问过程中将产生用户具体的操作日志,该操作日志将由具体服务发送保存到Kafka集群(或者可以写到具体文件,可以通过Flume对日志文件进行采集,发送到Kafka集群)。数据缓存到kafka集群后,利用..._sparkelasticsearch kafka git