A kafka storm topology to calculate and store rolling stats for consumer complaints data