??????
????openmessagin????????pull??????offset????LocalMessageCache??????????????????offset????0??????????MessageQueue
????????????????????
????????????PullConsumerImpl.registerPullTaskCallback????????????????MessageQueue????????nextPullOffset??????offset????????????????
------------------ ???????? ------------------
??????: "??????"<[email protected]>;
????????: 2018??2??11??(??????) ????7:24
??????: "users"<[email protected]>;
????: Re: ?????? ?????? ?????? rep eat logging error when using openmessaging
HI:
??????????????????Pull??????????????????openmessaging??????????????
rmq-4.2.0 ????openmessaging??????
Actually I'm not confusing about the pull-client, nor about the
openmessaging protocol, but the implementation of the openmessaging protocol in
rmq-4.2.0.
??rocketmq-4.2.0????????????????openmessaging????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????
There is an implementation of openmessaging in rocketmq-4.2.0. I used
it and find the error. My problem is how the error appears in the
implementation and how can I get over it. And I apologize for my confusing
description;
openmessaging
??????????https://github.com/apache/rocketmq/tree/master/openmessaging
The url of the openmessaging-implementation:
https://github.com/apache/rocketmq/tree/master/openmessaging
-----????????-----
??????:"????" <[email protected]>
????????:2018-02-11 19:03:00 (??????)
??????: users <[email protected]>
????:
????: ?????? ?????? ??????rep eat logging error when using openmessaging
??????
????????????openmesseg??????????????????pull??????pull??????????offset
????????pull????????????????offset??????????offset??????0????????????????????????????????????????????????????????????rocketmq??????
????push????????????????????offset??????pull??------------------
???????? ------------------
??????: "??????"<[email protected]>
????????: 2018??2??11??(??????) ????6:47
??????: "users"<[email protected]>;
????: Re: ?????? ??????rep eat logging error when using openmessaging
??????HI,
rocketmq-4.2.0????????openmessaging??????????????????????????????????????????????
Openmessaging is implemented in rocketmq-4.2.0, which I use in my
project. I'm just confused where is the mistake in the
openmessaging-implementation.
-----????????-----
??????:"????" <[email protected]>
????????:2018-02-11 17:45:52 (??????)
??????: users <[email protected]>
????:
????: ?????? ??????repeat logging error when using openmessaging
??????
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.ScheduledThreadPoolExecutor201(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]
