[I] The message queue is not in assigned list [rocketmq-flink]

[via GitHub]

andyyumiao opened a new issue, #107:
URL: https://github.com/apache/rocketmq-flink/issues/107

   I got the error when i consume rocketmq message in flink job：
   
    ```
      Caused by: org.apache.rocketmq.client.exception.MQClientException: The 
message queue is not in assigned list, message queue: MessageQueue 
[topic=yumiao1205, brokerName=broker-a, queueId=1]
   For more information, please visit the url, 
https://rocketmq.apache.org/docs/bestPractice/06FAQ
   ```
   
   My rocketmq version: 5.1.1
   flink version: 1.15.0
   


-- 
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: commits-unsubscr...@rocketmq.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org