Я получил потоковое приложение, которое подписано на две темы и публикует топи c. Одна подписка Topi c поступает из источника данных вне моего контроля и дает мне нулевые значения, где их не должно быть.
Итак, я думал о реализации NUll-Check в этом потоковом приложении, но мне нужно знать последнее опубликованное сообщение, потому что в данный момент потоковое приложение не имеет состояния. Поэтому я хотел бы добавить хранилище состояний в потоковое приложение, где я могу запросить последнее сообщение.
Это метод git? Существуют ли другие подходы к этой теме c помимо добавления «State» в потоковое приложение?