分布式消息服务KAFKA版-Kafka客户端使用建议:producer使用建议

时间:2024-11-11 15:36:51

producer使用建议

  1. 同步复制客户端需要配合使用:acks=all
  2. 配置发送失败重试:retries=3
  3. 发送优化:对于时延敏感的信息,设置linger.ms=0。对于时延不敏感的信息,设置linger.ms在100~1000之间。
  4. 生产端的JVM内存要足够,避免内存不足导致发送阻塞。
  5. 时间戳设置为与当地时间一致,避免时间戳为未来时间导致消息无法老化。
  6. 尽量复用producer,不要频繁创建producer。当producer开启幂等时(生产者客户端3.0及之后的版本默认开启幂等),生产消息会在服务端创建生产者状态对象,若频繁创建producer,会导致服务端创建大量生产者状态对象后无法及时回收,服务端内存占用飙升,进而导致服务端性能急剧下降。如果不需要使用幂等功能,请将“enable.idempotence”设置为“false”。
support.huaweicloud.com/usermanual-kafka/Kafka-client-best-practice.html