当前位置: 首页 > 图灵资讯 > java面试题> javaKafka面试题-如何避免消息积压

javaKafka面试题-如何避免消息积压

来源:图灵教育
时间:2024-05-27 13:41:26
提高消费并行度

 

批量消费

减少组件IO的交互次数

优先级消费

 

if (maxOffset - curOffset > 100000) { // TODO 消息堆积情况的优先处理逻辑 // 未处理的消息可以选择丢弃或者打日志 return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;}// TODO 正常消费过程return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;