Run Kafka:
docker-compose up
Run the producer:
sbt "runMain com.xebia.prodpoc.ProdPOC"
Run the consumer:
sbt "runMain com.xebia.conspoc.ConsPOC"
Run the UserActor app:
sbt "runMain com.xebia.useractorpoc.UserApp"
And see the logs:
[INFO] [com.xebia.useractorpoc.UserActor$] - Got command Add(1,Actor[akka://UserActorPoC/deadLetters#0])
[INFO] [com.xebia.useractorpoc.UserActor$] - Handling event Added(1)
Run the UserActor tests:
sbt "testOnly com.xebia.useractorpoc.UserActorSpec"