我已经创建了几个主题使用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”?
或者有没有别的方法?
暂无答案!
目前还没有任何答案,快来回答吧!