@AfterEach
    public void after() throws IOException {
        // Remove any state from previous test runs
        IntegrationTestUtils.purgeLocalStreamsState(streamsProp);
    }
Tests related to internal topics in streams
streams/src/test/java/org/apache/kafka/streams/integration/InternalTopicIntegrationTest.java