kafkaaggregator
