This is related to the topic mentioned in the below thread

JDBC Sink Connector -upserting into multiple tables from multiples topics using kafka-connect

I know its a bit older post. But my question is also around the same topic. The difference is I want to remove the suffix from the topic name and pass the remaining string as the table name in the sink connector. How can I achieve that?

If it is using SMT, can you please help to achieve that.

Topic Name: Source1-Emp,Source1-Company

Table Name: Emp, Company

Data load needs to happen from multiple topics to multiple tables using a single sink connector.

Can you please help me to implement that.

MUS