Writing schema name to payload or header

Dear Confluent community,

We have a single jdbc source connector for multiple tables. There is a need to identify the schema to which the record belongs. We don’t want the complete schema to sync with each record. Schema name ( not the complete schema) is what we only need maybe in the payload or header. Is there a way to achieve this.

If you use it with schema registry, it will only put a reference to the schema in the payload.
You can also use custom converters, that for example store the schema name in the header.

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.