private static void verifyPartitionResult(final QueryResult<VersionedRecordIterator<Integer>> result) {
        assertThat(result.getExecutionInfo(), is(empty()));
        if (result.isFailure()) {
            throw new AssertionError(result.toString());
        }
        assertThat(result.isSuccess(), is(true));
        assertThrows(IllegalArgumentException.class, result::getFailureReason);
        assertThrows(IllegalArgumentException.class, result::getFailureMessage);
    }
This method updates a record value in an existing timestamp, while it is retrieving records.
Since IQv2 guarantees snapshot semantics, we expect that the old value is retrieved.
streams/src/test/java/org/apache/kafka/streams/integration/IQv2VersionedStoreIntegrationTest.java