Utilities for publishing and subscribing Activities on Kafka, 
defining Activities queries for other databases (such as Cassandra),
and for defining and launching Hadoop MapReduce jobs for leaderboard
recalculation.