gaoyf opened a new issue #719: broadcasting consumer cannot consume message if offset file becomes read only in some situation! URL: https://github.com/apache/rocketmq/issues/719 **BUG REPORT** 1. Please describe the issue you observed: - What did you do (The steps to reproduce)? First, my consumer's message model is broacasting。 As is known to all, it store offset in local file. Second, my consumer has running for some time. Third, one day, the disk which stores the offset file is broken, so the offset cannot write to offset file. And I did not find anything until I restart my consumer. - What did you expect to see? The consumer can consume message normally! - What did you see instead? It cannot consume message, and I receive OFFSET_MOVED_EVENT continuously. 2. Please tell us about your environment: rocketmq 4.2. 3. Other information (e.g. detailed explanation, logs, related issues, suggestions how to fix, etc): The broker's log like bellow: ``` 2019-01-18 19:24:01 INFO PullMessageThread_49 - the request offset too small. group=digg-group, topic=digg-topic, requestOffset=156798, brokerMinOffset=172289, clientIp=/10.*.*.*:54437 2019-01-18 19:24:01 WARN PullMessageThread_49 - PULL_OFFSET_MOVED:correction offset. topic=digg-topic, groupId=digg-group, requestOffset=156798, newOffset=172289, suggestBrokerId=0 2019-01-18 19:24:18 INFO ClientManageThread_27 - subscription changed, group: digg-group OLD: SubscriptionData [classFilterMode=false, topic=digg-topic, subString=*, tagsSet=[], codeSet=[], subVersion=1547810638588, expressionType=null] NEW: SubscriptionData [classFilterMode=false, topic=digg-topic, subString=*, tagsSet=[], codeSet=[], subVersion=1547810658600, expressionType =null] 。。。 。。。 2019-01-18 19:24:38 INFO ClientManageThread_29 - subscription changed, group: digg-group OLD: SubscriptionData [classFilterMode=false, topic=digg-topic, subString=*, tagsSet=[], codeSet=[], subVersion=1547810658600, expressionType=null] NEW: SubscriptionData [classFilterMode=false, topic=digg-topic, subString=*, tagsSet=[], codeSet=[], subVersion=1547810678611, expressionType =null] ``` I investigated the bug and rocorded it [here](https://github.com/sohutv/sohu-tv-mq/wiki/%E5%B9%BF%E6%92%AD%E6%B6%88%E8%B4%B9OFFSET_MOVED_EVENT%E9%97%AE%E9%A2%98%E8%B0%83%E6%9F%A5).
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
