First of event aggregation using spark streaming and kafka