THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Describe the new thing you want to do in appropriate detail. This may be fairly extensive and have large subsections of its own. Or it may be a few sentences. Use judgement based on the scope of the change.
I will use the KeyValueStore as an example. Window and Session will have a similar structure.
We will provide a MockStoreFactory to generate Mock store builders:
...
| 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 InMemoryKeyValueStoreMockKeyValueStore(name);
}
} |
Compatibility, Deprecation, and Migration Plan
...