The data engineering team at an ecommerce company wants to ingest the clickstream data from the source system in a reliable way. The solution should provide built-in performance benefits and ease of use on the client side as well. Which solution would you implement on the source system to achieve high write throughput with reliability?