Communicating with kafka using akka actors

Let’s write simple example of communicating with Apache Kafka using Akka actors. Our application will demonstrate two actors that are playing Ping Pong with each other. If you are familiar with the startup activator template - minimal-akka-scala-seed…

Connect Flink with Kinesis /Kinesalite using Scala

Kinesalite provides local simulation of kinesis this will enable to simulate local instance of Kinesis on machine and you can execute all…

Filtering using Scala Parser Combinators

So I got interesting task to enable record filtering according to some rules that we get from configuration represented as text.

well so far we know two things :

Repost , Scala matrix library. Nicely implemented and explained