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] {

Keybase proof

I hereby claim:

  • I am naikyworld on github.
  • I am naikyworld (https://keybase.io/naikyworld) on keybase.
  • I have a public key whose fingerprint is E2B6 B5A2 F0FC 10CB 3875 D148 918B D6CB DB4C BAEF

To claim this, I am signing this object: