@BeforeEach
    public void before(final TestInfo testInfo) throws Exception {
        cluster = CLUSTER;
        prepareTest(testInfo);
    }
Tests local state store and global application cleanup.
streams/src/test/java/org/apache/kafka/streams/integration/ResetIntegrationTest.java