all-things-risingwave

How are modifications to the same key treated in an append-only source like Kafka? Is there an upsert option based on the key?

I'm curious about how modifications to the same key are handled in an append-only source like Kafka. Additionally, I would like to know if there is an upsert option based on the key.

Na

Naveen Nagarajan

Asked on Sep 18, 2022

Yes, modifications to the same key in an append-only source like Kafka can be treated as upserts if you declare the key as a primary key in the create source statement.

Sep 19, 2022Edited by