У меня есть приложение kafka, которое использует тему и пишет в другую тему. Регистрация ведется с slf4j. Он регистрирует информацию и ошибки в отдельных файлах. У моего приложения есть проблема, и иногда встречается ошибка INVALID_FETCH_SESSION_EPOCH.
Проблема в том, что эта ошибка заканчивается в моем информационном файле, и приложение зависает навсегда и нуждается в перезагрузке. Одно из решений - найти корень этой неверной проблемы эпохи, которая сейчас не имеет отношения к моим вопросам.
Моя проблема в том, как я могу проверить свои журналы на наличие этой ошибки и автоматически перезапустить приложение, когда это произойдет. Я реализовал свой собственный регистратор, расширив Logger и ILoggerFactory, но они все еще не могут проверить эту ошибку. Кажется, что Кафка использует другой Logger для записи.
Я тоже не могу проверить файлы журналов, так как они создаются с помощью скользящей политики и будут создавать много хлопот. Есть ли что-нибудь, что в моих информационных файлах будет проверено моим пользовательским методом до записи?