Kafka Connect can not use a different schema version

Kafka Connect
1

Hello,

I deployed two kafka connectors: source debezium and sink jdbc for sql server.

I have one table being streamed down from source to sink connector. However, after I add a new column in the source table and let’s suppose I can not do the same changes in the target table by adding the new column as well.

I can read from a custom kafka consumer using a specific avro schema without showing the new column.

The question is can I do the same by using the sink connector and insert only the fields before the schema changes?

I tried to use SMT SetSchemaMetadata to use version a different version and it does not work.

Which use cases Can I use SMT SetSchemaMetadata?

Thank you for your help

2

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