TopicCollect.aggregate(
    [{
      "$group" :
        {
          _id : {topic_id: "$topic_id"},