Simple App To Store Everything In Data Store From Kafka

Akka Libraries
1

Hi,

I would like to build an app using an Akka library that

  1. pull from kafka (batch)
  2. extract some info (id & event_number) from message, doesn’t require de-serialisation
  3. store it into in-memory data store with timestamp
  4. run for some time (running time is given at the start of application, e.g. 1 hour), doing step 1,2,3
  5. store the data into a file before the application gets terminated (time limit)

Any example code or suggestions?