When user defined as mapping from any DBMS to Kafka target using Schema Registry/Avro, a topic is created in Kafka and a subject with a initial version of schema is created in Schema Registry.
The Avro definition will contain a JSON like string that reflects the fields definitions of mapped source fields.
To trigger a refresh and generate a source table DDL change
- Refresh source table in Director's catalog to retrieve the definition after DDL change.
- Generate a new schema version for the subject in Schema Registry based on the new source table fields definition.
- Refresh target topic definition in Director to reflect the new schema version.
- Refresh the fields mapping in Director to:
- Remove suppressed fields
- Add new fields added and default map them with "Copy method"
This feature can be access from the GUI menu by right-clicking a mapping.