作者回复: Rocket MQ的事务机制我不太了解,不敢妄言,哈哈~
作者回复: 赋值消息的key为该id,这样能保证它们去到同一个分区。
作者回复: 有什么报错日志吗?
作者回复: 可能的原因有:1. 这个分区上有无法处理的消息或corrupted消息使得consumer无法跳过,你可以单独创建一个standalone consumer,只消费这个分区看看是否真的存在这样的消息;2. 你做过增加分区的操作,consumer需要一段时间才能发现这个新分区
最好还是查一下日志,看看日志中有没有什么发现