Использование STATE_CLEANUP_DELAY_MS_CONFIG

Question

в StreamsConfig есть параметр STATE_CLEANUP_DELAY_MS_CONFIG, который говорит: «Количество времени в миллисекундах для ожидания перед удалением состояния после переноса раздела. Будут удалены только каталоги состояний, которые не были изменены, по крайней мере, state.cleanup.delay.ms»;

У нас есть несколько каталогов состояний из-за перебалансировки, развертываний и т. Д. В файловой системе

1. Это очистит эти каталоги? Я попробовал этот параметр, перезапустил потребителя, но старые директории состояний все еще там

Answer 1

Обратите внимание, что Kafka Streams будет удалять только каталоги задач , которые вложены в state.dir, и только для текущего приложения. Таким образом, если у вас есть несколько каталогов состояний , поскольку вы изменили application.id, вам нужно будет удалить старые каталоги состояний вручную.