线上 Kafka 某 Topic 积压了上千万条消息,消费者处理速度远低于生产速度,最有效的快速止损手段是?

中间件

  1. A.删除 Topic 后重建,从头开始消费
  2. B.缩小消费者 fetch 批量大小,降低单次处理耗时
  3. C.把消费者组的 session.timeout 调大
  4. D.紧急扩分区并增加消费者实例,让消费并行度追上生产速度