Подключиться к нескольким 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());
}
}