public Topic(String name,ConsumerConnector consumerConnector,int numStreams){
  this(name,consumerConnector,numStreams,new LinkedBlockingQueue<String>(MAX_BUFFER_SIZE));
}

public Topic ( String name , ConsumerConnector consumerConnector , int numStreams ) { this ( name , consumerConnector , numStreams , new LinkedBlockingQueue < String > ( MAX_BUFFER_SIZE ) ) ; }
creates a new topic object .
