add DistributedGroupByConsumer