イベント ソーシング パラダイムに従って実装された Flink アプリケーションがあります。イベントとコマンドの両方がいくつかの Kafka トピックに保存されます。
アプリケーションには、リカバリとプロダクションの 2 つの起動モードがあります。まず、回復モードを使用して、イベント トピックからアプリケーションの状態 (セーブポイント) を回復します。このモードでは、コマンドはまったく読み取られません。すべてのイベント トピックが処理されると、セーブポイントが手動で (コマンド ラインから) トリガーされ、アプリケーションが停止します。次に、生産モードで糸プロセスが開始されます。そのモードでは、アプリケーションはイベントとコマンドの両方を処理します。
このプロセスをプログラムで実行したいと思います。それを行うには、いくつかの疑問が生じます... アプリケーション自体はどのようにできますか:
- kafka ソースが完全に読み取られたことを検出しますか?
- プログラムでセーブポイントをトリガーしますか?
- プログラムで停止して開始しますか？
ありがとうございました！