Kafka Connect JDBC接收器连接器

Question

我正在尝试将来自主题的数据（json数据）写入MySql数据库。我想我需要一个JDBC接收器连接器。

我如何配置连接器以将主题中的json数据映射到如何将数据插入数据库。

我能找到的文件只有这个。

“接收器连接器需要了解架构，因此您应该使用合适的转换器，例如架构注册表附带的Avro转换器，或启用了架构的JSON转换器。如果存在Kafka记录键，则可以是基元类型或连接结构，记录值必须是连接结构。从连接结构中选择的字段必须是基元类型。如果主题中的数据格式不兼容，则可能需要实现自定义转换器。”

但是如何配置呢？有例子吗？

Answer 1

我想这意味着您需要使用合流模式注册表？

对于“更好的”模式支持，那么是。但不，这不是必需的。

您可以将JsonConverter与schemas.enable=true一起使用

但是,您的JSON消息需要如下所示,

{
   "schema" : {
      ... data that describes the payload
   }, 
   "payload": {
      ... your actual data
   }
}

关于这个格式的参考，你可以看到这个博客

您可以使用Kafka流或KSQL更容易地将“无模式”JSON转换为schema-d Avro有效负载