分布式消息服务Kafka版-为什么Kafka实例常常发生Rebalance,导致消息拉取失败?:解决方法/排查思路

时间:2023-11-01 16:23:06

解决方法/排查思路

场景一:未能及时发送心跳请求

解决方法:建议在消费者客户端将session.timeout.ms值设置为heartbeat.interval.ms值3倍以上。

场景二:消费者消费时间间隔过长

排查思路:

  1. 检查单条消息的处理时间是多久,处理max.poll.records条消息会不会超过max.poll.interval.ms时间。
  2. 消息处理流程是否有网络行为,如写数据库、调用后端API等,在发生Rebalance的场景下后端是否正常。

解决方法:建议在消费者客户端将max.poll.records值减小。

support.huaweicloud.com/kafka_faq/kafka-faq-200426036.html