Your question is very general, so I’ll give a general answer from my point of view. First, I’ve got two usage scenario: cases where I’m reading data from kafka, processing it and writing some output back to kafka, for these I’m using kafka streams exclusively. cases where either the data source or sink is not … Read more
There are three ways this can be achieved: 1. Post Materialization with SourceQueue You can use Source.queue that materializes the Flow into a SourceQueue: case class Weather(zipCode : String, temperature : Double, raining : Boolean) val bufferSize = 100 //if the buffer fills up then this strategy drops the oldest elements //upon the arrival of … Read more
This answer is based on akka-stream version 2.4.2. The API can be slightly different in other versions. The dependency can be consumed by sbt: libraryDependencies += “com.typesafe.akka” %% “akka-stream” % “2.4.2” Alright, lets get started. The API of Akka Streams consists of three main types. In contrast to Reactive Streams, these types are a lot … Read more