用例是使用kafka连接器同时写入多个表。
在第一条评论后编辑
"insert.mode": "upsert",
"delete.enabled": "true",
"topics": "cars.best, airplanes.best",
"table.name.format": "CARS, AIRPLANES",
"pk.mode": "record_key",
"pk.fields": "cars_id" - for one of the tables , "pk.fields": "airplane_id" - for the other one of the tables ,
从carst主题到CARS表格,从airlae主题到AIRPLANES 的设置是什么
JDBC接收器连接器(以及大多数其他接收器连接器(根据所使用的主题的名称写入表/集合,但只能在一个服务器/架构/数据库下写入。
因此,将topics
或topicPattern
设置为从多个主题消费