I would like to build an app using an Akka library that
- pull from kafka (batch)
- extract some info (id & event_number) from message, doesn’t require de-serialisation
- store it into in-memory data store with timestamp
- run for some time (running time is given at the start of application, e.g. 1 hour), doing step 1,2,3
- store the data into a file before the application gets terminated (time limit)
Any example code or suggestions?