@AfterEach
    public void shutdown() throws Exception {
        if (kafkaStreams != null) {
            kafkaStreams.close(ofSeconds(30));
        }
        IntegrationTestUtils.purgeLocalStreamsState(streamsConfiguration);
        CLUSTER.deleteAllTopicsAndWait(0L);
    }
Try to read inputValues from {@code resources/QueryableStateIntegrationTest/inputValues.txt}, which might be useful
for larger scale testing. In case of exception, for instance if no such file can be read, return a small list
which satisfies all the prerequisites of the tests.
streams/src/test/java/org/apache/kafka/streams/integration/QueryableStateIntegrationTest.java