Skip to content

Instantly share code, notes, and snippets.

@nambrot

nambrot/kafka_join.scala

Created December 2, 2017 23:35
Show Gist options
  • Save nambrot/50da7eaec92309306457988cb6620b0b to your computer and use it in GitHub Desktop.
Save nambrot/50da7eaec92309306457988cb6620b0b to your computer and use it in GitHub Desktop.
Download ZIP
Raw
kafka_join.scala
val combinedEvents: KStream[Integer, (Option[HeartRateEvent], Option[BloodPressureEvent])] =
heartRateEvents
.outerJoin(
bloodPressureEvents,
(hrEvent, bpEvent: Option[BloodPressureEvent]) => (hrEvent, bpEvent),
JoinWindows.of(60.minutes.toMillis),
integerSerde,
new JsonSerde[Option[HeartRateEvent]],
new JsonSerde[Option[BloodPressureEvent]]
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment