flink-demo

介绍

flink流处理案例 反洗钱功能测试

软件架构

wordCount为基本功能测试 其他类为反洗钱demo代码

安装教程

1.安装mysql 新建数据库 命名为flink(数据库连接方式、用户名、密码、库名及表名均在SinkMysql中配置) 2.导入sql文件 位于resources/flink_test.sql 3.安装rabbitmq 文中使用的用户名密码均为admin 如需修改 请在FraudDetectionJob及Producer类中进行相应配置 4.启动rabbitmq 5.启动FraudDetectionJob类 开启flink监听 6.启动Producer开始生产数据

使用说明

//TODO

参与贡献

1. Fork 本仓库
2. 新建 Feat_xxx 分支
3. 提交代码
4. 新建 Pull Request