public static <K, V> KeyValueStoreTestDriver<K, V> create(final Class<K> keyClass, final Class<V> valueClass) {
        final StateSerdes<K, V> serdes = StateSerdes.withBuiltinTypes("unexpected", keyClass, valueClass);
        return new KeyValueStoreTestDriver<>(serdes);
    }
Create a driver object that will have a {@link #context()} that records messages
{@link ProcessorContext#forward(Object, Object) forwarded} by the store and that provides default serializers and
deserializers for the given built-in key and value types (e.g., {@code String.class}, {@code Integer.class},
{@code Long.class}, and {@code byte[].class}). This can be used when store is created to rely upon the
ProcessorContext's default key and value serializers and deserializers.

@param keyClass   the class for the keys; must be one of {@code String.class}, {@code Integer.class},
                  {@code Long.class}, or {@code byte[].class}
@param valueClass the class for the values; must be one of {@code String.class}, {@code Integer.class},
                  {@code Long.class}, or {@code byte[].class}
@return the test driver; never null
streams/src/test/java/org/apache/kafka/streams/state/KeyValueStoreTestDriver.java