ContextConfiguration.java 文件源码

@Value("${kafka.subscribed.topics}")
public void setKafkaSuscribedTopics(final String rawKafkaSubscribedTopics) {

    final List<String> topicNumThreadPairs = splitCsStrings(rawKafkaSubscribedTopics);
    this.kafkaSubscribedTopics = topicNumThreadPairs.stream().map(p -> {
        final List<String> topicNumThreadPair = Splitter.on(':').omitEmptyStrings().splitToList(p);
        return new TopicInfo(topicNumThreadPair.get(0), topicNumThreadPair.size() == 2 ? Integer.valueOf(topicNumThreadPair.get(1)) : 1);
    }).collect(Collectors.toList());
}