Skip to content

Instantly share code, notes, and snippets.

@nambrot

nambrot/kafka_setup.scala

Created December 2, 2017 23:34
Show Gist options
  • Save nambrot/6113ef2dfede69d308e200c2401011eb to your computer and use it in GitHub Desktop.
Save nambrot/6113ef2dfede69d308e200c2401011eb to your computer and use it in GitHub Desktop.
Download ZIP
Raw
kafka_setup.scala
val bloodPressureStream: KStream[String, String] = builder.stream("rawBloodPressureEvents")
val heartRateStream: KStream[String, String] = builder.stream("rawHeartRateEvents")
val bloodPressureEvents: KStream[Integer, Option[BloodPressureEvent]] =
bloodPressureStream
.mapValues(toEvent[BloodPressureEvent])
.map((_, v: BloodPressureEvent) => (v.userId, Some(v)))
val heartRateEvents: KStream[Integer, Option[HeartRateEvent]] =
heartRateStream
.mapValues(toEvent[HeartRateEvent])
.map((_, v: HeartRateEvent) => (v.userId, Some(v)))
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment