В следующей статье говорится, что Kafka Streams, если они используют оконные функции,'cksdb 'создаст сегмент для сохранения окон.
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Streams+Internal+Data+Management
The second difference is about RocksDB instances: instead of using a
single instance, Streams uses multiple instances (called “segments”)
for different time periods. After the window retention time has passed
old segments can be dropped
Isэто все еще имеет место, в нашем приложении я пытаюсь идентифицировать эти сегменты, чтобы создать некоторую автоматизацию для удаления этих файлов, но пока наше приложение работает как 3 недели, а время хранения окна составляет один день, я не могу найти 21 такой файл сегмента ...
Является ли эта статья точной?
Спасибо за ответы ...