scala编写的sparkjob,包括消费kafka日志,写入elasticsearch,读取elasticsearch数据,计算日志信息。监听redis缓存,读取redis大量数据,高并发写入数据库
语言:Scala · GitHub 星标:6 · Fork:3
在 GitHub 上查看原仓库