Question 510
A streaming lakehouse accumulates changes from multiple Kafka-like sources. The current environment exhibits the following problem: late telemetry changes an earlier day after reports are published. Which corrective action addresses the root cause?
Explanation
Correct Answer
Retain raw events and correct affected serving windows. Backfills keep derived views consistent with true event time.
Incorrect Answers
Events from two topics use the same local identifier. Identifiers can collide across independent producers.
An append-only output should represent updates and deletions from source CDC. Current state requires upsert and delete handling.
A restart replays microbatches after an uncertain sink acknowledgment. Replay safety must be implemented at the destination.