告警采集平台,Flink1.14.4,Kafka-2.8,ElasticSearch-7.3.2,Flink读取Kafka消息,实时检测三个场景,一是当前访问IP或者域名是否黑名单地址,二是当前连接端口是否敏感生产环境端口,三是检测一段时间内连续登录失败后突然又登录成功的场景。
在数据仓库建设中,经常会使用到数据血缘追踪方面的功能,本项目实现了对hql集合进行静态分析,获取hql对应的血缘图(表血缘 + 字段血缘)
一个神奇的框架,让Flink&Spark开发更简单!一站式大数据实时平台.
混合型科学大数据流水线系统,包含丰富的处理器组件,提供Shell、DSL、Web配置界面、任务调度、任务监控等功能
kingbus是一个基于raft强一致协议实现的分布式MySQL binlog 存储系统。它能够充当一个MySQL Slave从真正的Master上同步binglog,并存储在分布式集群中;同时又充当一个MySQL Master将集群中的binlog 同步给其他Slave。