Confluent OA 2025 | Message Deduplication, Sliding Window & Stack Validation

Problem 1 - Kafka Message De-duplication Ledger Problem Statement You are configuring an event interceptor for a Kafka topic. You are given: An array of strings messages. A sorted integer array timestamps. The message messages[i] arrives at time timestamps[i]. A message is allowed if the same payload has not been successfully processed within the previous 10 seconds (inclusive). If an identical message was processed within that 10-second window, the current message must be dropped. Return all allowed messages while preserving ...