特牛生活网

湖仓一体电商项目(十八):业务实现之编写写入DWD层业务代码_dwd可以直接ads吗-CSDN博客

网友收藏
文章浏览阅读863次,点赞7次,收藏7次。另外,在Flink处理此topic中每条数据时都有获取对应写入后续Kafka topic信息,本业务对应的每条用户日志数据写入的kafka topic为“KAFKA-DWD-BROWSE-LOG-TOPIC”,所以代码可以复用。以上代码执行后在,在对应的Kafka “KAFKA-DWD-BROWSE-LOG-TOPIC” topic中都有对应的数据。代码中Kafka Connector中属性“scan.startup.mode”设置为“earliest-offset”,从头开始消费数据。_dwd可以直接ads吗