Currently, the sink requires that the Iceberg identifier fields be set on the table to identify a row for CDC and upsert operations. This PR adds a new configuration option that allows the ID columns to be set via the config, in cases when the identifier fields are not set on a table.
Currently, the sink requires that the Iceberg identifier fields be set on the table to identify a row for CDC and upsert operations. This PR adds a new configuration option that allows the ID columns to be set via the config, in cases when the identifier fields are not set on a table.