rob-9 commented on PR #885: URL: https://github.com/apache/flink-agents/pull/885#issuecomment-4972811418
> Could tombstone emission be opt-in, for example through `kafkaActionStateTombstoneEnabled` defaulting to `false`? Yeah, agreed. Can we make cleanup safe by default though? Maybe we could stamp tombstones with the checkpoint id that triggered the prune; `rebuildState()` applies one only if id <= restored checkpoint, so restoring C0 skips C1's tombstones. But this would only protect the record until compaction deletes it. This can be a follow-up. I'll add the opt-in flag to this PR for now. -- 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]
