Status
Current state: "Under Discussion"
Discussion thread: here
Github PR: here
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
Motivation
def process(processorSupplier: () => Processor[K, V], stateStoreNames: String*)
should be:
def process(processorSupplier: => Processor[K, V], stateStoreNames: String*)
Public Interfaces
org.apache.kafka.streams.scala.kstream.KStream.process
Proposed Changes
def process(processorSupplier: => Processor[K, V], stateStoreNames: String*)
Compatibility, Deprecation, and Migration Plan
Overload and deprecate, then remove the deprecated.
Rejected Alternatives
NA