springboot项目配置多个kafka的示例代码

前言：

Spring Boot 是一种基于 Spring Framework 的快速开发框架，可用于构建独立的、可执行的 Spring 应用程序。而 Kafka 是一种高吞吐量分布式发布订阅消息系统，常用于大数据领域。在使用 Spring Boot 开发项目时，我们通常会遇到需要配置多个 Kafka 的情况，以满足不同场景下的需求。

示例代码：

下面是一个配置多个 Kafka 的 Spring Boot 项目示例代码。首先，我们需要在项目的配置文件中配置多个 Kafka 的相关参数：

# Kafka1 配置
kafka1.bootstrap-servers=localhost:9092
kafka1.consumer.group-id=group1
kafka1.consumer.auto-offset-reset=latest
kafka1.consumer.enable-auto-commit=true

# Kafka2 配置
kafka2.bootstrap-servers=localhost:9093
kafka2.consumer.group-id=group2
kafka2.consumer.auto-offset-reset=earliest
kafka2.consumer.enable-auto-commit=false

接下来，我们需要在应用程序中定义多个 Kafka 相关的配置类，并分别使用不同的 Kafka 配置参数创建对应的 KafkaTemplate 和消费者：

@Configuration
public class Kafka1Config {
    
    @Value("${kafka1.bootstrap-servers}")
    private String bootstrapServers;

    @Bean
    public KafkaTemplate kafkaTemplate1() {
        Map configs = new HashMap<>();
        configs.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
        // 其他配置参数
        
        return new KafkaTemplate<>(new DefaultKafkaProducerFactory<>(configs));
    }
    
    @Bean
    public MyKafkaConsumer kafka1Consumer() {
        Map configs = new HashMap<>();
        configs.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
        // 其他配置参数
        
        return new MyKafkaConsumer(configs);
    }
}

@Configuration
public class Kafka2Config {
    
    @Value("${kafka2.bootstrap-servers}")
    private String bootstrapServers;

    @Bean
    public KafkaTemplate kafkaTemplate2() {
        Map configs = new HashMap<>();
        configs.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
        // 其他配置参数
        
        return new KafkaTemplate<>(new DefaultKafkaProducerFactory<>(configs));
    }
    
    @Bean
    public MyKafkaConsumer kafka2Consumer() {
        Map configs = new HashMap<>();
        configs.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
        // 其他配置参数
        
        return new MyKafkaConsumer(configs);
    }
}

在上述示例代码中，我们分别创建了 Kafka1Config 和 Kafka2Config，每个配置类都根据配置文件读取对应的 Kafka 参数，并创建了对应的 KafkaTemplate 和 MyKafkaConsumer 实例。

总结：

配置多个 Kafka 的 Spring Boot 项目非常简单，只需要在配置文件中定义多个 Kafka 的相关参数，并在应用程序中分别创建对应的 KafkaTemplate 和消费者即可。通过这种方式，我们可以轻松地实现在同一个应用中同时使用多个 Kafka 实例，以满足不同场景下的需求。希望上述示例代码能对你理解和使用多个 Kafka 提供一定的帮助。