Incrementally process deleted or updated data from external tables?

[coderwf]

Can I send some deleted or updated data messages to Kafka, and then have RisingWave process it? If so, please give a simple example

[lmatz]

Hi @coderwf

Yes, as long as your data messages follow the format of debezium,
https://docs.risingwave.com/sql/commands/sql-create-source#change-data-capture-cdc
https://debezium.io/documentation/reference/stable/connectors/postgresql.html#postgresql-events
https://docs.risingwave.com/ingestion/sources/kafka#data-format-examples

Thank you for posting your questions here! Please note that our primary communication channel is the Slack community: risingwave.com/slack.
We have AI bot on slack who can give you concrete examples.