У меня есть потоковое приложение kafka, написанное на scala.
Я создаю хранилища состояний значений ключа сохранения и добавляю их в узлы процессора в приложении.
Я помещаю значения в хранилище состояний как пара значений ключа, но когда я пытаюсь получить доступ к этому значению с тем же ключом в другом процессоре, он дает мне значение null, а метод approximateNumEntries() дает ноль.
Я не понимаю, почему эти значения исчезли из хранилища состояний.
Это происходит периодически, например, я перезапустил своих брокеров kafka, и это начало происходить снова.
Я очень новичок в потоках kafka и хранилищах состояний, поэтому любая помощь приветствуется.