
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.