Thanks Guys, Sorry Sachin, I'm using consumer offset. It's lower than Broker max offset for few partition in same topic, my attention is blocked by some remoting calls. I'll watch your consume logic more carefully. My mistake. No more again. Follow advices Yukon suggested, it's my point.
------------------ ???????? ------------------ ??????: "sachin.shashi";<sachin.sha...@gmail.com>; ????????: 2018??1??25??(??????) ????7:29 ??????: "users"<users@rocketmq.apache.org>; ????: Re: RocketMQ offset getting difference between broker and consumer Thanks Yukon, Very frequently we are getting difference between consumer offset and Broker max offset for few partition within same topic,we are explicitly resetting offset for that topic, nothing found much from code, any idea please help. On Jan 23, 2018 5:35 PM, "yukon" <yu...@apache.org> wrote: Hi, There are two offsets for a queue/partition: * broker min offset: the minimum message offset in the current broker, which points to the earliest message. * broker max offset: the maximum message offset in the current broker, which points to the newest message. As for consumer, should concern the consumer offset(min offset<= consumer offset <= max offset). The consumer offset will be updated automatically according to the consumer consumed progress if you are using the PushConsumer, and the consumer offset can be changed easily through MQAdmin tool. If you noticed that the consumer offset always is lower than broker max offset, you should keep a watchful eye on your consume logic, check whether it's blocked by some remoting calls. It's worth noting that the consumer offset is not accurate and real-time if you are using TAG/SQL to filter the message. Let me know if you have any other questions. Regards, yukon On Mon, Jan 22, 2018 at 11:07 PM, ???? <jarvisb...@foxmail.com> wrote: Hi Sir, I'm a new guy who just join the RocketMQ community. I have no idea what happened before I came. Then, below what I said is my personal advice: "If a foreign guy come to my home and say"Hello??RocketMQ", I'll feel happy:), at least no personal emotion?? But if this man come to my bed room without knock the door. I may have emotion" :( We're human beings, sometimes we may face someone rude/something bad: the "broker"?? we may have uncomfortable sences. but the consumer with gentle actions will help us make our product better, this is a CN tradition. As the EN saying:"Customer is the god". We're friends in community. This is a deal so that we can communicate. Thanks a lot for your knidly advice. Although a little guy in community I'll try my best to help you. I can see the mail. Thanks for your reply. No need send a private e-mail to me, if your error didn't happen now. Any questions you can feel free to seek services from me or the other community guys. If there is somewhere special make you feel confused, my apology. Regards JARVIS ------------------ ???????? ------------------ ??????: "sachin.shashi";<sachin.sha...@gmail.com>; ????????: 2018??1??22??(??????) ????10:59 ??????: "users-help"<users-h...@rocketmq.apache.org>;"users"<users@rocketmq.apache.org>;"issues"<iss...@rocketmq.apache.org>; ????: RocketMQ offset getting difference between broker and consumer Hi all,Recently we observed that, RocketMQ offset getting difference between broker offset and consumer offset,e.g. I have created topic with 4 partitions, whenever message coming to partition whose broker offset not matches to consumer offset messages not getting picked up, Not sure why getting difference between both offset, Kindly suggest what could be cause for this difference and what needs to be done so that it should not differ. Regards SACHIN
