Я реализую наблюдатель каталога с помощью инфраструктуры Akka: он просто создает Actor для каждого нового файла, создаваемого в каталоге, и материализует поток с помощью FileTailSource, который отправляет содержимое файла в тему Kafka.
Я бы хотел иметь возможность восстановиться после сбоя, не читая снова те же строки в файле.По этой причине состояние субъекта сохраняет смещение строки для каждого файла.
Я использую журнал сохраняемости Akka для сохранения состояний и снимок для уменьшения количества записей в журнале (с помощью deleteMessages).
Это действительно излишне, так как мне нужно только сохранить последнее состояние в отличие от архитектуры источника событий.Журнал LevelDB также не поддерживается, поскольку не поддерживается на платформе AIX, на которой запускается приложение, я застрял с журналом в памяти и его ограничениями.
Есть ли более легкая альтернатива этой архитектуре?Возможно, я мог бы использовать простую сериализацию для сохранения состояния на диск, но мне любопытно, поддерживается ли это в Akka Persistence?