开发者社区> 问答> 正文

批量消费消息时异常

批量消费消息时,是不是一条异常了, return ConsumeConcurrentlyStatus.RECONSUME_LATER;// 重试 这一批的消息会都被重新拉取?

for (int i = 0; i < 1000; i++) {  
            try {  
                Message msg = new Message("TopicTest",// topic  
                        "TagA",// tag  
                        ("Hello RocketMQ " + i).getBytes()// body  
                );  
                SendResult sendResult = producer.send(msg);  
                System.out.println(sendResult);  
            } catch (Exception e) {  
                e.printStackTrace();  
                Thread.sleep(1000);  
            }  
        }

本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 https://developer.aliyun.com/article/706511 点击链接欢迎加入感兴趣的技术领域群。

展开
收起
ciip 2019-08-08 17:06:51 658 0
0 条回答
写回答
取消 提交回答
问答地址:
问答排行榜
最热
最新

相关电子书

更多
基于RocketMQ Connect 构建全新数据流转处理平 立即下载
FLINK在大规模实时无效广告流量检测中的应用 立即下载
低代码开发师(初级)实战教程 立即下载