建设部网站官网 造价鉴定上海传媒公司有哪些

调整 Kafka 客户端参数需结合生产者、消费者和 Broker 的配置，以实现性能优化、可靠性保障或资源限制。以下是关键参数的调整方法和注意事项：

---

一、生产者参数调整

1. ‌max.request.size‌

   • ‌作用‌：限制单个请求的最大字节数（包括消息键、值及头部信息）‌。
   • ‌适用场景‌：需发送大消息时（如文件流），需调高此值。
   • ‌示例配置‌（Spring Boot）：

spring:kafka:producer:properties:max.request.size: 10485760  # 10MB

        2. ‌batch.size‌

• ‌作用‌：控制单个批次（Batch）的大小，默认 16KB。增大此值可提高吞吐量，但可能导致延迟增加‌。
• ‌示例配置‌：

spring:kafka:producer:properties:batch.size: 32768  # 32KB

  3.linger.ms‌

• ‌作用‌：生产者发送批次前的等待时间。增大此值可合并更多消息，减少请求次数，但增加延迟。

‌建议值‌：根据业务容忍的延迟调整（如 10-100ms）。

---

二、消费者参数调整

1. ‌max.partition.fetch.bytes‌

   • ‌作用‌：控制消费者单次从分区拉取的最大数据量，默认 1MB。需与 Broker 的 message.max.bytes 匹配‌3。
   • ‌示例配置‌：

spring:kafka:consumer:properties:max.partition.fetch.bytes: 10485760  # 10MB

1. ‌fetch.max.bytes‌

   • ‌作用‌：限制消费者单次请求从所有分区拉取的总数据量。
   • ‌公式建议‌：fetch.max.bytes ≥ max.partition.fetch.bytes × 分区数。

2. ‌session.timeout.ms‌

   • ‌作用‌：消费者与 Broker 的心跳超时时间。超时后触发重平衡。
   • ‌建议值‌：默认 10秒，网络不稳定时可适当增大（如 30秒）。

---

三、Broker 关联参数

1. ‌message.max.bytes‌
   • ‌作用‌：Broker 允许接收的单条消息最大字节数，需与生产者的 max.request.size 一致‌。
   • ‌Broker 配置示例‌（server.properties）：

message.max.bytes=10485760  # 10MB

四、Spring 配置示例

spring:kafka:bootstrap-servers: localhost:9092producer:key-serializer: org.apache.kafka.common.serialization.StringSerializervalue-serializer: org.apache.kafka.common.serialization.StringSerializerproperties:max.request.size: 10485760  # 10MB ‌:ml-citation{ref="3" data="citationList"}batch.size: 32768            # 32KB ‌:ml-citation{ref="3" data="citationList"}linger.ms: 50                # 50msconsumer:group-id: my-groupauto-offset-reset: earliestkey-deserializer: org.apache.kafka.common.serialization.StringDeserializervalue-deserializer: org.apache.kafka.common.serialization.StringDeserializerproperties:max.partition.fetch.bytes: 10485760  # 10MB ‌:ml-citation{ref="3" data="citationList"}fetch.max.bytes: 52428800             # 50MBsession.timeout.ms: 30000             # 30秒

五、注意事项

1. ‌参数匹配‌：生产者的 max.request.size 必须 ≤ Broker 的 message.max.bytes，否则消息会被拒绝‌36。
2. ‌性能权衡‌：增大批次或拉取量可提高吞吐，但会占用更多内存并增加延迟。
3. ‌版本兼容性‌：确保客户端版本与 Broker 兼容（如 Kafka 3.0+ 推荐使用 Spring Kafka 3.0+）‌