湖仓一体电商项目(十六):业务实现之编写写入ODS层业务代码-CSDN博客

网站介绍:文章浏览阅读1.1k次,点赞28次,收藏25次。这里也可以不设置从头开始消费Kafka数据,而是直接启动实时向MySQL表中写入数据代码“RTMockDBData.java”代码,实时向MySQL对应的表中写入数据,这里需要启动maxwell监控数据,代码才能实时监控到写入MySQL的业务数据。以上代码执行后在,在对应的Kafka “KAFKA-DIM-TOPIC”和“KAFKA-ODS-TOPIC”中都有对应的数据。针对用户日志数据可以启动代码“RTMockUserLogData.java”,实时向日志采集接口写入数据。_湖仓一体电商项目