我的问题是关于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连接器能用这样的方式设计吗?
1条答案
按热度按时间r1zk6ea11#
jdbc sink connect只能将一个主题写入一个表。
但是,如果您愿意的话,您可以使用fork代码对数据执行任何操作