# DB数据写入kafka示例

本示例主要演示将关系型数据库中数据写入kafka中。

主要步骤如下：

准备数据
新建转换作业
拖拽图元
配置组件属性
运行
查看数据
提交版本

# 准备数据

创建表orderinfo_kafka。

CREATE TABLE `orderinfo` (
  `ordercode` varchar(32) CHARACTER SET utf8mb3 COLLATE utf8mb3_general_ci NOT NULL COMMENT '订单号',
  `amount` int DEFAULT NULL COMMENT '数量',
  `price` varchar(32) CHARACTER SET utf8mb3 COLLATE utf8mb3_general_ci DEFAULT NULL COMMENT '价格',
  `manufacturer` varchar(32) CHARACTER SET utf8mb3 COLLATE utf8mb3_general_ci DEFAULT NULL COMMENT '厂商',
  `createtime` timestamp NULL DEFAULT NULL COMMENT '创建时间',
  `createuser` varchar(32) CHARACTER SET utf8mb3 COLLATE utf8mb3_general_ci DEFAULT NULL COMMENT '创建人',
  `updatetime` timestamp NULL DEFAULT NULL COMMENT '更新时间',
  PRIMARY KEY (`ordercode`) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb3 ROW_FORMAT=DYNAMIC COMMENT='订单表';
 

 INSERT INTO `dws_front_dev`.`orderinfo` (`ordercode`, `amount`, `price`, `manufacturer`, `createtime`, `createuser`, `updatetime`) VALUES ('001', 1000, '5000', 'xingyun', '2018-12-12 00:00:00', 'zhangcong', '2018-12-13 00:00:00');
INSERT INTO `dws_front_dev`.`orderinfo` (`ordercode`, `amount`, `price`, `manufacturer`, `createtime`, `createuser`, `updatetime`) VALUES ('003', 1500, '7000', '枫禾林木', '2018-12-12 00:00:00', '魏雨', '2018-12-13 12:00:00');
INSERT INTO `dws_front_dev`.`orderinfo` (`ordercode`, `amount`, `price`, `manufacturer`, `createtime`, `createuser`, `updatetime`) VALUES ('005', 1300, '8000', '天威科技', '2018-12-12 00:00:00', '王林', '2019-12-01 00:00:00');
INSERT INTO `dws_front_dev`.`orderinfo` (`ordercode`, `amount`, `price`, `manufacturer`, `createtime`, `createuser`, `updatetime`) VALUES ('006', 2000, '5000', '微云科', '2018-12-12 00:00:00', '王林2', '2019-12-01 00:20:11');
INSERT INTO `dws_front_dev`.`orderinfo` (`ordercode`, `amount`, `price`, `manufacturer`, `createtime`, `createuser`, `updatetime`) VALUES ('011', 1800, '5500', '00微云科技', '2022-12-31 00:00:00', '魏雨', '2023-01-04 10:11:22');
INSERT INTO `dws_front_dev`.`orderinfo` (`ordercode`, `amount`, `price`, `manufacturer`, `createtime`, `createuser`, `updatetime`) VALUES ('013', 1302, '5302', '天威科技', '2024-05-24 00:00:00', '魏雨', '2024-05-23 16:59:00');
INSERT INTO `dws_front_dev`.`orderinfo` (`ordercode`, `amount`, `price`, `manufacturer`, `createtime`, `createuser`, `updatetime`) VALUES ('014', 1300, '5400', '天威科技', '2024-05-22 00:00:00', '魏雨', '2024-05-23 17:09:00');