如何在kafka jdbc接收器连接器上使用表名转换?

o75abkj4  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(230)

我已经创建了几个主题使用Kafkapostgres源连接器。他们的名字如下:

server1.public.table1
server1.public.table2
server1.public.table3

我正在使用jdbc接收器连接器将这些数据加载到不同位置的postgres。我希望postgres表以“table1”、“table2”和“table3”的名称创建。
我在sink.json文件中使用了以下属性

"topics.regex": "server1.public.(.*)",  
"transforms": "route",
"transforms.route.regex": "([^.]+)\\.([^.]+)\\.([^.]+)",
"transforms.route.replacement": "$3",
"transforms.route.type": "org.apache.kafka.connect.transforms.RegexRouter"

但它们不起作用。如何将上述转换的输出传递到“table.name.format”?
或者有没有别的方法?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题