bean326 opened a new issue #1111: 顺序消息第一次消费时间很久 URL: https://github.com/apache/rocketmq/issues/1111 测试环境： MQ和测试程序都在本地 生产者: Message msg = new Message(topic, tag, keys, content); SendResult result = producer.send(msg, new MessageQueueSelector() { @Override public MessageQueue select(List<MessageQueue> mqs, Message msg, Object arg) { Integer id = Integer.parseInt(arg.toString()); int index = id % mqs.size(); return mqs.get(index); } }, serverId); 消费者: DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(group); // Specify name server addresses. consumer.setNamesrvAddr(MQFactory.LOCAL_NAMESRV_ADDR); // Subscribe one more more topics to consume. consumer.subscribe(topic, tag); /** * 设置Consumer第一次启动是从队列头部开始消费还是队列尾部开始消费<br> * 如果非第一次启动，那么按照上次消费的位置继续消费 */ consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET); consumer.registerMessageListener(listener); //Launch the consumer instance. consumer.start(); listener里面的内容: @Override public ConsumeOrderlyStatus consumeMessage(List<MessageExt> msgs, ConsumeOrderlyContext context) { MessageExt message = msgs.get(0); LogUtils.info("收到消息 -> " + message.getMsgId() + ",内容 -> " + new String(message.getBody()) + ",key -> " + message.getKeys()); return ConsumeOrderlyStatus.SUCCESS; } 问题就是，每次消费者第一次启动后，生产者发来的消息总是要很久才能收到，最长时间超过1分钟，最短也是30秒以上 ，有什么办法可以缩短这个时间吗
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
