1. 批量消费:可以设置,通过 consumer.setConsumeMessageBatchMaxSize(N) 配置,默认 1(单条消费)。

  2. 重试机制:

    • 默认重试次数:普通消息 16次,顺序消息 无限次。

    • 触发条件:

      • 消费逻辑抛出异常

      • 消费超时(默认15分钟)

      • 返回 RECONSUME_LATER 状态

  3. 适用场景:

    • 批量消费:高吞吐场景(如日志处理)。

    • 重试:网络抖动、依赖服务短暂不可用、业务逻辑需重试(如支付回调)。

Logo

北京人形旗下天工造物具身智能开源社区,聚焦具身天工与慧思开物两大平台

更多推荐