Versions Compared

Key

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

...

Add the above methods, interfaces, classes to the DSL. Deprecate the existing overloads on KStream, KTable, and KGroupedStream that take more than the required parameters, for example, KTable#filter(Predicate, String) and KTable#filter(Predicate, StateStoreSupplier) will be deprecated. StateStoreSupplier will also be deprecated 

The new Interface `BytesStoreSupplier` BytesStoreSupplier supersedes the existing `StateStoreSupplier` StateStoreSupplier (which will remain untouched). This so we can provide a convenient way for users creating custom state stores to wrap them with caching/logging etc if they chose. In order to do this we need to force the inner most store, i.e, the custom store, to be a store of type `<Bytes, byte[]>`. 

...