Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
package org.apache.kafka.streams.internals;

public class MockKeyValueStoreBuilder<K, V>  extends AbstractStoreBuilder<K, V, StateStore> {

    public MockKeyValueStoreBuilder(final String storeName,
                                    final Serde<K> keySerde,
                                    final Serde<V> valueSerde,
                                    final Time time) {
        super(storeName, keySerde, valueSerde, time);
    }

    @Override
    public KeyValueStore build() {
        return new MockKeyValueStoreInMemoryKeyValueStore(name, false);
    }
}


Compatibility, Deprecation, and Migration Plan

...