多卡夫卡连接答案

【问题标题】：Multi-kafka connections多卡夫卡连接
【发布时间】：2023-02-15 23:24:10
【问题描述】：

有一个数据流应用程序。有必要连接并监听多个 Kafka 代理（不同的 ip 地址，超过 2 个）并写入其中一个。

请告知如何安排多卡夫卡连接？

单个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());
    }
}

预计同时安排和收听多个连接。

【问题讨论】：

标签： java apache-kafka spring-kafka

【解决方案1】：

Bootstrap 服务器配置选项接受一个集群的多个代理的 CSV 列表

如果您需要连接到不同的 Kafka 集群，请创建一个具有不同引导地址的 Bean

【讨论】：