探索Spring Boot与Kafka的完美融合：实战配置指南

import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.common.serialization.StringSerializer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.core.ProducerFactory;
import org.springframework.kafka.core.DefaultKafkaProducerFactory;
import java.util.HashMap;
import java.util.Map;
 
@Configuration
public class KafkaProducerConfig {
 
    @Bean
    public ProducerFactory<String, String> producerFactory() {
        Map<String, Object> props = new HashMap<>();
        props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
        props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
        props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
        // 这里可以添加更多的配置属性
        return new DefaultKafkaProducerFactory<>(props);
    }
}

这段代码定义了一个配置类KafkaProducerConfig，其中包含了一个Bean方法producerFactory，用于创建一个ProducerFactory实例。这个实例用于配置和创建Kafka生产者，以便在Spring Boot应用程序中发送消息到Kafka broker。在这个例子中，我们配置了生产者去连接本地的Kafka服务，并且指定了使用StringSerializer来序列化键和值。这个配置可以根据实际的Kafka服务器地址和序列化需求进行调整。