XiaoFeiASK commented on PR #1125: URL: https://github.com/apache/incubator-seata-go/pull/1125#issuecomment-4825514104
新增修改 pkg/integration/rocketmq/tcc_rocketmq_action.go 问题: offsetMsgId 解析失败时 commitLogOffset 默认为 0，继续发送 END_TRANSACTION 可能导致 broker 按错误 offset 处理半消息 修复: 当 offsetMsgId 为空或解析失败时，fallback 到 msgId 解析 commitLogOffset（与官方 client 行为对齐），并更新对应单测验证该 fallback 行为 影响: 避免发送无效 0 offset，提升事务消息可靠性，与 RocketMQ 官方客户端语义一致 -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
