Spring Kafka生产者配置文件详解

Spring Kafka 生产者配置文件详解

spring-kafka-producer.xml 文件用于配置 Spring Kafka 生产者。它定义了生产者与 Kafka 集群交互的方式，包括连接信息、序列化方式、消息发送策略等。

核心配置项：

• bootstrap.servers: Kafka 集群地址列表，用于建立初始连接。
• key.serializer: 消息键的序列化类。
• value.serializer: 消息值的序列化类。
• acks: 消息确认机制，控制消息持久性。
• retries: 消息发送失败后的重试次数。
• batch.size: 批量发送消息的大小阈值。
• linger.ms: 批量发送消息的延迟时间。
• compression.type: 消息压缩类型。

示例配置：

<beans ...="">
    <bean class="org.springframework.kafka.core.DefaultKafkaProducerFactory" id="kafkaProducerFactory">
        <constructor-arg>
            <map>
                <entry key="bootstrap.servers" value="localhost:9092">entry>
                <entry key="key.serializer" value="org.apache.kafka.common.serialization.StringSerializer">entry>
                <entry key="value.serializer" value="org.apache.kafka.common.serialization.StringSerializer">entry>
            map>
        constructor-arg>
    bean>

    <bean class="org.springframework.kafka.core.KafkaTemplate" id="kafkaTemplate">
        <constructor-arg ref="kafkaProducerFactory">constructor-arg>
    bean>
beans>

注意：

以上仅列举了部分常用配置项，更多配置项请参考 Spring Kafka 官方文档。