for ea_activity, now using separate stream for each hashtag and using activity metadata.