这与下面的主题有关
jdbc接收器连接器-使用kafka connect从多个主题向上插入多个表
我知道它有点老了。但我的问题也是围绕着同一个主题。区别在于我想从主题名中删除后缀,并将剩余的字符串作为表名传递到接收器连接器中。我怎样才能做到这一点?
如果它是使用smt,请您帮助实现这一点。
主题名称:source1 emp,source1公司
表名:emp,公司
需要使用单个接收器连接器从多个主题向多个表加载数据。
你能帮我实现吗。
亩
这与下面的主题有关
jdbc接收器连接器-使用kafka connect从多个主题向上插入多个表
我知道它有点老了。但我的问题也是围绕着同一个主题。区别在于我想从主题名中删除后缀,并将剩余的字符串作为表名传递到接收器连接器中。我怎样才能做到这一点?
如果它是使用smt,请您帮助实现这一点。
主题名称:source1 emp,source1公司
表名:emp,公司
需要使用单个接收器连接器从多个主题向多个表加载数据。
你能帮我实现吗。
亩
1条答案
按热度按时间m528fe3b1#
您的假设是正确的,即这可以通过单消息转换(smt)完成。举个例子: