Я создаю приложение весенней загрузки, которое будет создавать несколько тем.Я беру список названий тем и конфигураций из файла .csv.Я пытаюсь этот код, но он может создать только одну тему, но не выгодно создавать несколько тем, используя это.Есть ли способ создать несколько тем с помощью Spring?
@Bean
public KafkaAdmin admin(){
Map<String, Object> configs = new HashMap<>();
configs.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG,"localhost:9092");
return new KafkaAdmin(configs);
}
@Bean
public NewTopic topic1() {
NewTopic topic = new NewTopic(String.format("topic%d",1), 10, (short) 1);
Map<String, String> extraTopicConfig = new HashMap<String, String>();
extraTopicConfig.put(TopicConfig.CLEANUP_POLICY_CONFIG, "compact");
extraTopicConfig.put(TopicConfig.MIN_IN_SYNC_REPLICAS_CONFIG, "1");
topic.configs(extraTopicConfig);
return topic;
}