Когда вы материализуете магазин из SessionWindowKStream, он заставляет вас делать это как SessionStore, устанавливая Materialized<K,VR,SessionStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized).
Так что вы получаете SessionStore<org.apache.kafka.common.utils.Bytes,byte[]>.В этом типе хранилища вы можете выбирать по ключу, но не по ключу и времени, как в WindowStore, даже тип ключа - Windowed<K>.Поэтому вам нужно будет выполнить итерацию по нему, чтобы найти записи, связанные со временем, которые должны быть менее эффективными, чем запросы по времени.
Как можно использовать агрегированное хранилище сеансов Windowed<K> для запроса к хранилищус (ключ, время)?
Или, другими словами, почему в ReadOnlySessionStore нет findSessions -подобных методов (т. е. ограниченного по времени доступа), а в SessionStore?