Kafka 消息数据积压,Kafka 消费能力不足怎么处理?

  1. 提高partition数量,同时提高 consumer数量,**两者缺一不可,**如果缺一不可,则
  2. consumer 处理消息不及时导致的,增加拉取消息批数的大小,或者多线程方式消费消息,当然这建立在你消费可以忽略顺序性