Versions Compared

Key

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

...

Public Interfaces

New methods:

  • KStream<K,VOut> KStream#processValues(ProcessorSupplier<K, V, K, VOut> processorSupplier, String... stateStoreNames)
  • KStream<K,VOut> KStream#processValues(ProcessorSupplier<K, V, K, VOut> processorSupplier, Named named, String... stateStoreNames)

Modified methods:

  • KStream<KOut,VOut> KStream#process(ProcessorSupplier<K, V, KOut, VOut> processorSupplier, String... stateStoreNames)
  • KStream<KKStream<KOut,VOut> KStream#processValuesKStream#process(ProcessorSupplier<K, V, KKOut, VOut> processorSupplier, Named named, String... stateStoreNames)

Deprecated methods:

  • KStream#transform 
  • KStream#transformValues 
  • KStream#flatTransform 
  • KStream#flatTransformValues 

...