Я ищу ожидаемое поведение при перемещении хранилища состояний существующего приложения потоков в новое местоположение (через определение 'state.dir').Я не смог найти никакой документации по этому вопросу.
Я подумал, что она должна быть прозрачной и такой же, как и при остановке приложения потоков, хранилище удаляется вручную, а затем приложение запускается снова.В этом случае хранилище состояний извлекается из соответствующего внутреннего раздела журнала изменений.Но когда я изменил местоположение (например, из / tmp / kafka-streams на что-то еще), я заметил, что хранилище состояний было перенесено вниз по потоку (в тему B).Это ожидается?Мой поток довольно прост: из темы A -> агрегат (..) -> в тему B.
Спасибо!