# 读取表数据写入格式为avro写入到Kafka主题中

本示例主要演示从Mysql表中读取数据，写入格式为Avro，写入Kafka的test_avro_data主题中。

主要步骤如下：

准备数据
新建同步作业
拖拽图元
运行
查看数据
提交版本

# 准备数据

创建数据库dws_source作为源库

CREATE DATABASE IF NOT EXISTS dws_source;

创建表 t_user 作为源表，并给源表 INSERT 一些数据。

-- ---------------------------------------
-- Table structure for t_user
-- ---------------------------------------
DROP TABLE IF EXISTS dws_source.`t_user`;

CREATE TABLE dws_source.`t_user` (
  `id` int NOT NULL,
  `name` varchar(400) NOT NULL,
  `age` int DEFAULT NULL,
  PRIMARY KEY (`id`)
);

-- ----------------------------
-- Records of t_user
-- ----------------------------

INSERT INTO dws_source.t_user(id, name, age)VALUES(1, '张聪', 20);
INSERT INTO dws_source.t_user(id, name, age)VALUES(2, '王建国', 20);
INSERT INTO dws_source.t_user(id, name, age)VALUES(3, '王强', 20);
INSERT INTO dws_source.t_user(id, name, age)VALUES(4, '魏雨', 18);
INSERT INTO dws_source.t_user(id, name, age)VALUES(5, '刘飞', 18);