lkmxsxd opened a new issue, #121:
URL: https://github.com/apache/rocketmq-eventbridge/issues/121
1、内置DB
2、默认配置
3、RMQ-5.1.1
启动EB通过putEvents接口通过jmeter并发推送数据
filetest出现下述异常：
15:00:23.563@@@@@@@@[Remoting-PullConsumerExecutorService_1]@@WARN@@o.a.r.e.a.s.r.r.c.LitePullConsumerImpl[236]@@Local
cache is full, delay the pull task 100 ms for message queue MessageQueue
[topic=eventbridge%default%demo-bus_1687157833377, brokerName=broker-b,
queueId=0]
2023-06-19
15:00:23.566@@@@@@@@[Remoting-PullConsumerExecutorService_1]@@ERROR@@o.a.r.e.a.s.r.r.c.LitePullConsumerImpl[303]@@Error
occurs when pull message process, delay 200 ms for message queue MessageQueue
[topic=eventbridge%default%demo-bus_1687157833377, brokerName=broker-b,
queueId=0]
org.apache.rocketmq.client.exception.MQClientException: maxNums <= 0
For more information, please visit the url,
https://rocketmq.apache.org/docs/bestPractice/06FAQ
at
org.apache.rocketmq.client.impl.consumer.DefaultMQPullConsumerImpl.pullAsyncImpl(DefaultMQPullConsumerImpl.java:493)
at
org.apache.rocketmq.client.impl.consumer.DefaultMQPullConsumerImpl.pullAsyncImpl(DefaultMQPullConsumerImpl.java:553)
at
org.apache.rocketmq.client.impl.consumer.DefaultMQPullConsumerImpl.pullBlockIfNotFound(DefaultMQPullConsumerImpl.java:579)
at
org.apache.rocketmq.client.consumer.DefaultMQPullConsumer.pullBlockIfNotFound(DefaultMQPullConsumer.java:387)
at
org.apache.rocketmq.eventbridge.adapter.storage.rocketmq.runtimer.consumer.LitePullConsumerImpl$PullTask.run(LitePullConsumerImpl.java:241)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:266)
at java.util.concurrent.FutureTask.run(FutureTask.java)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
--
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]
