文件名称：Spark_Kafka_Elastic
文件大小：63KB
文件格式：ZIP
更新时间：2024-06-28 02:06:35
Java
用户活动监视器 介绍 该项目在单个网页上包含一个简单的用户活动监视器。 对于用户在网页上进行的每个鼠标移动操作，坐标将使用 REST 网络服务发送到网络服务器。 Web 服务将带有时间戳的坐标写入 Kafka 主题。 将有一个在后台运行的 Spark 流处理器，它从 Kafka 主题中读取坐标，识别该坐标所属的 Qadrant 并将数据索引到 Elastic Search 技术栈 SpringMVC Apache Spark（流媒体） 卡夫卡 弹性搜索 Maven 安装和入门 卡夫卡 从下载 Kafka 发行版 解压tar文件焦油-xzf kafka_2.10-0.8.2.0.tgz cd kafka_2.10-0.8.2.0 启动动物园管理员bin/zookeeper-server-start.sh 配置/zookeeper.properties 启动Kafka服务器bin/ka
【文件预览】：
Spark_Kafka_Elastic-master
----pom.xml(634B)
----ElasticSearch()
--------pom.xml(1KB)
--------src()
----readme.md(3KB)
----ActivityStreamProcessor()
--------pom.xml(2KB)
--------src()
----UserActivityMonitor()
--------pom.xml(3KB)
--------src()
--------.idea()