Подключиться к нескольким kafka из одного приложения

Есть приложение потоковой передачи данных. Необходимо одновременно подключиться и слушать из нескольких kafka (разные ip-адреса, более двух), а запись делать в одну kafka.

Не могу сообразить, как подключиться к нескольким kafka.

Configuration class для соединения с Kafka:

@Configuration public class KafkaProducer {

@Bean
public Map<String, Object> producerConfigs() {
    Map<String, Object> props = new HashMap<>();

    props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:29092");
    props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
    props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
    return props;
}

@Bean
public ProducerFactory<String, String> producerFactory() {
    return new DefaultKafkaProducerFactory<>(producerConfigs());
}

@Bean
public KafkaTemplate<String, String> kafkaTemplate() {
    return new KafkaTemplate<>(producerFactory());
}

}


Ответы (0 шт):