Источник событий в Флинк
У меня есть приложение Flink, которое было реализовано в соответствии с парадигмой поиска событий. И события, и команды хранятся в нескольких темах Kafka.
Приложение имеет два режима запуска: восстановление и производство. Во-первых, режим восстановления используется для восстановления состояния приложения (точки сохранения) из тем событий. В этом режиме команды не читаются вообще. После обработки всех тем событий точка сохранения запускается вручную (из командной строки) и приложение останавливается. Затем процесс пряжи запускается в производственном режиме. В этом режиме приложение обрабатывает как события, так и команды.
Я бы предпочел выполнить этот процесс программно. Для этого возникает несколько вопросов... Как может само приложение:
- обнаружить, что источники кафки были полностью прочитаны?
- вызвать точку сохранения программно?
- остановиться и начать программно?
Спасибо!