apache kafka - Partial updates in JDBC Sink connector

Question

I am trying to have multiple stream apps perform partial updates to a single target table by sending messages to output Kafka topic, which in turn using JDBCSinkConnector to push the data to the table.

For example, the Target table has | PK | c1 | c2. The first stream app inserts | PK | C1 | and the other stream app should be able to update the row by sending just | PK | c2 | in output topic.

I am not successful in making these partial updates work.

Answer 1

等待大神答复