lizhimins opened a new issue, #6205: URL: https://github.com/apache/rocketmq/issues/6205
分支：develop 问题：LitePullConsumer 使用 org.apache.rocketmq.client.impl.consumer.DefaultLitePullConsumerImpl#pull 从服务端获取消息。 继续追踪，我发现 pullSyncImpl 中 CommunicationMode 是 SYNC 的，对于 DefaultPullConsumer 是同时支持同步和异步获取消息的。客户端默认配置的 org.apache.rocketmq.client.consumer.DefaultLitePullConsumer#pullThreadNums = 20， 如果此时客户端被分配到的分区/队列数大于20，由于客户端的长轮询在服务端未返回，此时假设消息发送到了服务端没有长轮训的分区，此时消息就会延迟。 建议：litePull 模式下也支持 async pull message，使用异步通信来获取消息。 以上是我阅读代码发现的，具体行为是这样吗？ -- 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. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
