создание нескольких тем кафки с использованием Spring - PullRequest
0 голосов
/ 26 июня 2019

Я создаю приложение весенней загрузки, которое будет создавать несколько тем.Я беру список названий тем и конфигураций из файла .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;

}
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...