需求描述： 1、数据从 Kafka 写入 Mysql。 2、相关配置存放于 Mysql 中，通过 Mysql 进行动态读取。 3、此案例中的 Kafka 是进行了 Kerberos 安全认证的，如果不需要自行修改。 4、Kafka 数据为 Json 格式，获取到的数据根据操作类型字段进行增删改操作。 5、读取时使用自定义 Source，写入时使用自定义 Sink。 6、消费 Kafka 数据时自定义反序列化。 1）导入依赖 这里的依赖比较冗余，大家可以根据各自需求做删除或保留。 <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">...
