@AfterEach
    public void tearDown() {
        testDriver.close();
    }
Unit test of {@link WordCountDemo} stream using TopologyTestDriver.
streams/examples/src/test/java/org/apache/kafka/streams/examples/wordcount/WordCountDemoTest.java