Kafka Jdbc sink connector upsert issue

I am using jdbc sink connect for db2 and I have a use case of using upsert but it should populate create timestamp in case of insert and update timestamp in case of updates. What is the best approach to achieve this. I am stuck here as I can see that jdbc sink connect only uses only same set of columns for both insert and update based on value schema.

Thanks Lara. Can you please share an example where I can see a working example.

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