主要任务

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

思路分析

实现步骤

（1）从 Kafka dwd_trade_order_pre_process 主题读取订单预处理数据；

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

（3）写入Kafka 取消订单主题。

图解

代码编写

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 主题

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 主题

bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092  --topic dwd_trade_cancel_detail