@Override
                public Consumer<byte[], byte[]> getConsumer(final Map<String, Object> config) {
                    throw new IllegalStateException();
                }
Create a new test diver instance.

@param builder builder for the topology to be tested
@param config the configuration for the topology
@param initialWallClockTimeMs the initial value of internally mocked wall-clock time
streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java