spring kafka中有没有多个生产者的代码样本？

在Spring Kafka中，可以通过配置多个生产者来实现消息的发送。下面是一个示例代码，展示了如何在Spring Kafka中配置和使用多个生产者：

首先，需要在Spring Boot的配置文件中配置Kafka的相关属性，包括Kafka服务器地址、端口号等信息。例如，可以在application.properties文件中添加以下配置：

spring.kafka.producer.bootstrap-servers=127.0.0.1:9092
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer

然后，在Spring Boot的启动类中添加@EnableKafka注解，启用Kafka的自动配置功能。

接下来，可以创建多个生产者实例，并通过@Autowired注解将它们注入到需要使用的类中。例如，假设有两个生产者，可以创建两个对应的配置类：

@Configuration
public class KafkaProducerConfig1 {

    @Value("${spring.kafka.producer.bootstrap-servers}")
    private String bootstrapServers;

    @Bean
    public ProducerFactory<String, String> producerFactory1() {
        Map<String, Object> configProps = new HashMap<>();
        configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
        configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
        configProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
        return new DefaultKafkaProducerFactory<>(configProps);
    }

    @Bean
    public KafkaTemplate<String, String> kafkaTemplate1() {
        return new KafkaTemplate<>(producerFactory1());
    }
}

@Configuration
public class KafkaProducerConfig2 {

    @Value("${spring.kafka.producer.bootstrap-servers}")
    private String bootstrapServers;

    @Bean
    public ProducerFactory<String, String> producerFactory2() {
        Map<String, Object> configProps = new HashMap<>();
        configProps.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
        configProps.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
        configProps.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
        return new DefaultKafkaProducerFactory<>(configProps);
    }

    @Bean
    public KafkaTemplate<String, String> kafkaTemplate2() {
        return new KafkaTemplate<>(producerFactory2());
    }
}

在需要使用生产者的类中，可以通过@Autowired注解将对应的KafkaTemplate注入进来，并使用它发送消息。例如：

@Service
public class KafkaProducerService {

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate1;

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate2;

    public void sendMessage1(String topic, String message) {
        kafkaTemplate1.send(topic, message);
    }

    public void sendMessage2(String topic, String message) {
        kafkaTemplate2.send(topic, message);
    }
}

以上代码展示了如何在Spring Kafka中配置和使用多个生产者。通过创建多个ProducerFactory和KafkaTemplate实例，并将它们注入到需要使用的类中，可以实现多个生产者的功能。在需要发送消息的方法中，可以根据需要选择对应的KafkaTemplate来发送消息。

请注意，以上示例代码仅供参考，实际使用时需要根据具体的业务需求进行适当的修改和调整。