Skip to content

Instantly share code, notes, and snippets.

@note

note/gist:146c1833491c5560da97

Created October 30, 2015 12:42
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save note/146c1833491c5560da97 to your computer and use it in GitHub Desktop.
Save note/146c1833491c5560da97 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
gistfile1.txt
val kafka = new ReactiveKafka()
val consumerProperties = toConsumerProperties(config, new MyDecoder())
val publisher = kafka.consume(consumerProperties)
Source(publisher)
.map { ...
.runForeach(_ => ())
val publisher2 = kafka.consume(consumerProperties)
Source(publisher2)
.map { ...
.runForeach(_ => ())
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment