This page is meant as a template for writing a KIP. To create a KIP choose Tools->Copy on this page and modify with your content and replace the heading with the next KIP number and a description of your issue. Replace anything in italics with your own description.
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