??????
rocketmq??client????push????offset??pull??????offset????
push????????offset??????????????????????????????????????????????broker????????????????????????????????????????
openmessaging????????????????????????????????????????openmessaging??????rocketmq??client??client??????????????????????????
------------------ ???????? ------------------
??????: "??????"<[email protected]>;
????????: 2018??2??11??(??????) ????5:40
??????: "users"<[email protected]>;
????: ????: ??????repeat logging error when using openmessaging
??????
Hi??
??????????
Thanks for your attention.
????????offset????openmessaging??????????????????????????????????????????????????????????????????????????????????????openmessaging????????????????????
Acturally, the offset of rmq is set by openmessaging-implementation. What
I would like to know is that if there is anyone who has tried
openmessaging-implementation and know why error appears.
??????
???????? ????
?????????? 2018-02-11 16:49
???????? users
?????? ??????repeat logging error when using openmessaging
????????????????????
org.apache.rocketmq.client.exception.MQClientException: offset < 0 ????
????????offset????????????
????????pull??????offset????????????????????????????????offset??????????push??????
------------------ ???????? ------------------
??????: "??????"<[email protected]>;
????????: 2018??2??11??(??????) ????4:41
??????: "users"<[email protected]>;
????: repeat logging error when using openmessaging
Hi all,
I meet a problem when pulling data from rocketmq using openmessaging
implementation.
During my usage, I did get data, but at the same time I also got error
message in my log file. I got a 70GB error log per day.
In my error log file, the same error repeated like this:
2018-02-11 16:40:19,882 [ERROR]
[io.openmessaging.rocketmq.consumer.PullConsumerImpl$1.doPullTask(PullConsumerImpl.java:151)]
[PullMsgThread-5_nm_test_group_12115] - A error occurred in pull message
process.
org.apache.rocketmq.client.exception.MQClientException: offset < 0
For more information, please visit the url, http://rocketmq.apache.org/docs/faq/
at
org.apache.rocketmq.client.impl.consumer.DefaultMQPullConsumerImpl.pullSyncImpl(DefaultMQPullConsumerImpl.java:175)
at
org.apache.rocketmq.client.impl.consumer.DefaultMQPullConsumerImpl.pull(DefaultMQPullConsumerImpl.java:161)
at
org.apache.rocketmq.client.impl.consumer.DefaultMQPullConsumerImpl.pull(DefaultMQPullConsumerImpl.java:156)
at
org.apache.rocketmq.client.consumer.DefaultMQPullConsumer.pull(DefaultMQPullConsumer.java:251)
at
io.openmessaging.rocketmq.consumer.PullConsumerImpl$1.doPullTask(PullConsumerImpl.java:133)
at
org.apache.rocketmq.client.consumer.MQPullConsumerScheduleService$PullTaskImpl.run(MQPullConsumerScheduleService.java:172)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
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)
Is there anybody who has ever used openmessaging implementation and knows
how it happens and how to avoid it ?
rmq version: 4.2.0,
Java version: 1.8_25.
Thanks a lot.
--------------
[email protected]
