THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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
...