rishisolutionsbysms commented on issue #13691: URL: https://github.com/apache/iceberg/issues/13691#issuecomment-3130815731
I'm facing issue with the Iceberg Sink Connector for Kafka Connect. The connector is not able to implement the upsert functionality as expected. It is creating new records instead of updating existing ones. The connector is configured to use the `_id` field as the primary key, but it seems to be ignoring this and treating all records as new inserts. **Sink connector Table related config** ``` "iceberg.tables": "iceberg.table_staging", "iceberg.tables.default-namespace": "iceberg", "iceberg.tables.default-id-columns": "_id", "iceberg.tables.default-partition-by": "AccountId", "iceberg.tables.dynamic-enabled": "false", "iceberg.tables.auto-create-enabled": "true", "iceberg.tables.evolve-schema-enabled": "true", ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
