草庐IT

JdbcSinkConnector

全部标签

Kafka Connect JdbcSinkConnector的schema处理

kafkaconnect当写入到Mysql这类的关系型数据库时,使用JdbcSinkConnector,且kafka中的数据需要具备schemas,否则是无法写入的。只有两种数据可以写入:1.使用ConfluentSchemaRegistry在写入kafka时,就用Avro、Protobuf或JSONSchema的converter进行schema的转换2.带着schema的Json数据{"schema":{"type":"struct","optional":false,"version":1,"fields":[{"field":"ID","type":"string","optional