主要任务
从Kafka 读取订单预处理表数据,筛选取消订单明细数据,写入Kafka 对应主题。
思路分析
实现步骤
(1)从 Kafka dwd_trade_order_pre_process 主题读取订单预处理数据;
(2)筛选取消订单明细数据:保留修改了order_status 字段且修改后该字段值为 “1003“ 的数据;
(3)写入Kafka 取消订单主题。
图解
代码编写
测试
创建 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 主题
启动 DwdTradeOrderPreProcess __与 DwdTradeCancelDetail类 开始启动
bin/kafka-console-consumer.sh --bootstrap-server hadoop102:9092 --topic dwd_trade_cancel_detail

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