一对多连接Kafka接收器连接器

pdtvr36n  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(467)

我的问题是关于Kafka接收器连接器配置。
我有一个特定的案例:有一个主题,包含带有实体信息的消息:

{
  "id": 1,
  "name": "name",
  "attributes": {
     "attr1":{ value: val1, type: typ1},
     "attr2":{ value: val2, type: typ2}        
  }
}

我需要kafka接收器连接器以以下方式将其保存在两个表中:

|id|name|
|1|name|

|parent_id|name|value|type|
|1|attr1|val1|typ1|
|1|attr2|val2|typ2|

所以我需要将它保存在两个表中并保持一对多的连接
Kafka的Flume连接器能用这样的方式设计吗?

r1zk6ea1

r1zk6ea11#

jdbc sink connect只能将一个主题写入一个表。
但是,如果您愿意的话,您可以使用fork代码对数据执行任何操作

相关问题