public KafkaMessageListenerContainer(ConsumerFactory<K,V> consumerFactory,ContainerProperties containerProperties,TopicPartitionInitialOffset... topicPartitions){
  super(containerProperties);
  Assert.notNull(consumerFactory,"A ConsumerFactory must be provided");
  this.consumerFactory=consumerFactory;
  if (topicPartitions != null) {
    this.topicPartitions=Arrays.copyOf(topicPartitions,topicPartitions.length);
  }
 else {
    this.topicPartitions=containerProperties.getTopicPartitions();
  }
}

public KafkaMessageListenerContainer ( ConsumerFactory < K , V > consumerFactory , ContainerProperties containerProperties , TopicPartitionInitialOffset ... topicPartitions ) { super ( containerProperties ) ; Assert . notNull ( consumerFactory , "A ConsumerFactory must be provided" ) ; this . consumerFactory = consumerFactory ; if ( topicPartitions != null ) { this . topicPartitions = Arrays . copyOf ( topicPartitions , topicPartitions . length ) ; } else { this . topicPartitions = containerProperties . getTopicPartitions ( ) ; } }
construct an instance with the supplied configuration properties and specific topics / partitions / initialoffsets .
