I have put an example of basic aggregation/persistence usage based on Storm, Kafka and Cassandra here on github:
https://github.com/svendx4f/stormRoomOccupancy
There's a detailed explanation of how it works on my blog:
http://svendvanderveken.wordpress.com/2013/07/30/scalable-real-time-state-update-with-storm/