У нас есть приложение для потоковой обработки, и в потоке мы извлекаем id и сохраняем его в хранилище состояний. Мой пример использования очень прост, мы храним идентификатор, потому что, когда мы получим запрос, мы будем проверять, присутствует ли идентификатор в магазине или нет. Проблема у нас, все события будут иметь уникальный идентификатор, и хранилище состояний в конечном итоге приведет к нехватке памяти. Данные в государственном хранилище не нужны через некоторое время.
Есть ли способ иметь некоторую конфигурацию, чтобы состояние очищало данные через некоторое время в зависимости от конфигурации?
Другой подход заключается в отправке надгробного сообщения с ключом, чтобы запись была удалена из хранилища. Но я чувствую, что это как-то больше работы, так как нам нужно отправить еще одно сообщение в тему и обработать его, чтобы удалить запись
- Как выполняется обработка ошибок в случае, если мы идем со вторым подходом?
- Есть ли способ вручную удалить запись из магазина. Если это так, каково будет влияние удаления записи из хранилища состояний?