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