KTables и базовые хранилища состояний RocksDB имеют семантику, подобную сжатой теме в Kafka. Хранение не основано на времени, скорее, запись становится пригодной для удаления, если вы отправляете сообщение с заданным ключом и нулевым значением в тему ввода.