public Map<String, Set<String>> getConsumerThreadIdsPerTopic() {
        Map<String, Set<String>> consumerThreadIdsPerTopicMap = new HashMap<String, Set<String>>();
        for (Map.Entry<String, Integer> e : topicCountMap.entrySet()) {
            Set<String> consumerSet = new HashSet<String>();
            final int nCounsumers = e.getValue().intValue();
            for (int i = 0; i < nCounsumers; i++) {
                consumerSet.add(consumerIdString + "-" + i);
            }
            consumerThreadIdsPerTopicMap.put(e.getKey(), consumerSet);
        }
        return consumerThreadIdsPerTopicMap;
    }
public Map < String , Set < String > > getConsumerThreadIdsPerTopic ( ) { Map < String , Set < String > > consumerThreadIdsPerTopicMap = new HashMap < String , Set < String > > ( ) ; for ( Map . Entry < String , Integer > e : topicCountMap . entrySet ( ) ) { Set < String > consumerSet = new HashSet < String > ( ) ; final int nCounsumers = e . getValue ( ) . intValue ( ) ; for ( int i = 0 ; i < nCounsumers ; i ++ ) { consumerSet . add ( consumerIdString + "-" + i ) ; } consumerThreadIdsPerTopicMap . put ( e . getKey ( ) , consumerSet ) ; } return consumerThreadIdsPerTopicMap ; }
@return topic-&gt;(consumerIdString-0,consumerIdString-1..)