Answer-first summary for fast verification
Answer: Configure the stream processing solution to process data within a single partition in order, using checkpoints and watermarking to handle interruptions and ensure data consistency.
To ensure that all trades within a single partition are processed in order and to handle interruptions without losing data, the stream processing solution should be configured to process data within a single partition in order. Checkpoints and watermarking should be used to save the state of the processing and to handle late-arriving data. This approach ensures data consistency and fault tolerance, which are critical for a financial trading platform.
Author: LeetQuiz Editorial Team
Ultimate access to all questions.
You are tasked with developing a stream processing solution for a financial trading platform. The platform needs to process high-frequency trading data in real-time to detect and prevent fraudulent activities. The data is partitioned by the timestamp of each trade. How would you configure the stream processing solution to ensure that all trades within a single partition are processed in order and that the system can handle interruptions without losing data?
A
Configure the stream processing solution to process data in parallel across multiple partitions, ignoring the order of trades within a partition.
B
Configure the stream processing solution to process data within a single partition in order, using checkpoints and watermarking to handle interruptions and ensure data consistency.
C
Disable checkpoints and watermarking to improve processing speed and rely on manual intervention to handle interruptions.
D
Use a batch processing approach to process the data in large batches, ignoring the real-time requirements of the system.
No comments yet.