Springboot集成kafka(环境搭建+演示)|超级详细，建议收藏

@Configuration
@EnableKafka
public class KafkaProducerConfig {
 
    @Value("${kafka.bootstrap-servers}")
    private String bootstrapServers;
 
    @Bean
    public ProducerFactory<String, String> producerFactory() {
        Map<String, Object> props = new HashMap<>();
        // 设置Kafka服务器地址和端口
        props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
        // 设置值序列化器
        props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
        props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
        // 其他配置属性...
        return new DefaultKafkaProducerFactory<>(props);
    }
 
    @Bean
    public KafkaTemplate<String, String> kafkaTemplate() {
        return new KafkaTemplate<>(producerFactory());
    }
}

这段代码定义了一个配置类，它使用@EnableKafka注解启用Kafka并提供了一个KafkaTemplate bean，用于发送消息。通过@Value注解注入了Kafka服务器的配置属性，并通过ProducerFactory和DefaultKafkaProducerFactory配置了生产者。这个配置类可以被Spring Boot应用上下文自动检测并使用。