主要任务

从Kafka 读取订单预处理表数据,筛选取消订单明细数据,写入Kafka 对应主题。

思路分析

实现步骤

(1)从 Kafka dwd_trade_order_pre_process 主题读取订单预处理数据;

(2)筛选取消订单明细数据:保留修改了order_status 字段且修改后该字段值为 “1003“ 的数据;

(3)写入Kafka 取消订单主题。

图解

实时数仓(十八)DWD层-交易域取消订单事务事实表 - 图1

代码编写

https://gitee.com/luan_hao/gmall-flink/blob/master/gmall-realtime/src/main/java/com/apache/gmall/app/dwd/db/DwdTradeCancelDetail.java

测试

创建 dwd_trade_cancel_detail 主题

  1. bin/kafka-topics.sh --zookeeper hadoop102:2181,hadoop103:2181,hadoop104:2181/kafka --create --replication-factor 1 --partitions 1 --topic dwd_trade_cancel_detail

消费 dwd_trade_cancel_detail 主题

  1. bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --topic dwd_trade_cancel_detail
启动 DwdTradeOrderPreProcess __DwdTradeCancelDetail 开始启动 实时数仓(十八)DWD层-交易域取消订单事务事实表 - 图2 观察消费者数据

实时数仓(十八)DWD层-交易域取消订单事务事实表 - 图3



有如上图数据,则测试成功
若有收获,就点个赞吧