static <K> K extractStoreKey(final byte[] binaryKey,
                                 final StateSerdes<K, ?> serdes) {
        final byte[] bytes = new byte[binaryKey.length - TIMESTAMP_SIZE - SEQNUM_SIZE];
        System.arraycopy(binaryKey, 0, bytes, 0, bytes.length);
        return serdes.keyFrom(bytes);
    }
Safely construct a time window of the given size,
taking care of bounding endMs to Long.MAX_VALUE if necessary
streams/src/main/java/org/apache/kafka/streams/state/internals/WindowKeySchema.java