Want only one topic for all tables - PostgresCdcSourceConnector

Hello Team,

We have set up PostgresCdcSourceConnector as a source. This connector has automatically created different topics for each table. I want only one topic for all tables and will need a prefix in the payload where I can identify from which table, data is coming.

Can you guys please help us with how to do that?

Thanks in advance.
Harsh Shah

Assuming each table has the same schema, then you may be able to use RegexRouter transform to override the outgoing topic name that the Connector uses for producing records.

1 Like