Skip to content

Instantly share code, notes, and snippets.

@joan38

joan38/Streams.scala

Last active May 19, 2018 19:09
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save joan38/5f4756eec735534eb708dd153936594e to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save joan38/5f4756eec735534eb708dd153936594e to your computer and use it in GitHub Desktop.
Download ZIP
Raw
Streams.scala
implicit class KStreamOps[K, V](stream: KStreamS[K, V]) {
def toTopic(implicit record: Record[K, V], produced: Produced[K, V]) = stream.to(record.topic)
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment