Want only one topic for all tables - PostgresCdcSourceConnector

Confluent Cloud
1

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

2

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