mikunjrathwa opened a new issue, #13986: URL: https://github.com/apache/iceberg/issues/13986
We are loading data from kafka topics to iceberg using a kafkak connector. We used the tabular version of kafka connector that had an option "iceberg.tables.upsert-mode-enabled": "true", which enables the upsert mode. i.e. When two messages exists in the topic with same value of primary key(s), it used to update the target record in the iceberg table with data from the latest kafka message. Do we have the similar option in case of apache version of kafka connect? Referring the below documentation, I dont see any configuration key to set upsert mode to true. https://iceberg.apache.org/docs/nightly/kafka-connect/ -- 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]
