Status

Current state: "Under Discussion"

Discussion thread: here

Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).

Motivation

Serdes in the Scala wrapper are usually passed in implicit so this is a proposal to make the same on Materialized, Serialized, Consumed and Produced constructor functions.

Public Interfaces

Introduction of:

org.apache.kafka.streams.kstream.scala.Materialized

org.apache.kafka.streams.kstream.scala.Serialized

org.apache.kafka.streams.kstream.scala.Produced

org.apache.kafka.streams.kstream.scala.Consumed

Proposed Changes

Add the scala versions of Materialized, Serialized, Consumed and Produced.

Compatibility, Deprecation, and Migration Plan

NA

Rejected Alternatives

NA