Skip to content

Instantly share code, notes, and snippets.

@fcecilia
fcecilia / KeyValueImplicits.scala
Created September 13, 2016 08:32
Implicit for KafkaStream
import org.apache.kafka.streams.KeyValue
import org.apache.kafka.streams.kstream.{KeyValueMapper, ValueMapper}
/**
* Implicit conversions that provide us with some syntactic sugar when writing stream transformations.
*/
object KeyValueImplicits {
implicit def valueMapper[V1, V2](f: V1 => V2): ValueMapper[V1, V2] = new ValueMapper[V1, V2] {