Oracle テーブルは継続的に挿入されるため、scala でループを使用して 10 秒ごとに Oracle テーブルをクエリしています。選択リクエストを作成してから、Oracle から n 行を含む n json 文字列を作成し、それを Elasticsearch にプッシュします。その後、ES に挿入した Oracle テーブルから n 行を削除する削除リクエストを作成します。私は完全に初心者のアプローチを開発しました。それで、OracleからESにリアルタイムまたはマイクロバッチデータをロードし、Oracleから削除するためのより良いアプローチを提案できますか。logstach や SreamSets について聞いたことがあります。何か考えはありますか？ありがとう