Kinesis Data Streamsからデータを受け取り、リアルタイムで集計処理（スライディングウィンドウなど）を行った結果を再びKinesis Data Streamsに出力するアプリケーションを、SQLのみを使用して構築したいと考えています。どのサービスを使用すべきですか。

DynamoDBテーブルの特定の項目（Item）に対して、複数のユーザーが同時に更新を行おうとしています。データ整合性を保つために、条件付き書き込み（Conditional Writes）を使用して、更新前に項目のバージョン番号を確認したいと考えています。これによって防ぐことができる問題はどれですか。