chuanxo opened a new pull request, #10437: URL: https://github.com/apache/rocketmq/pull/10437
### Brief Description `ClientManageProcessor.heartBeat()` 在循环外只创建了一个 `ClientChannelInfo` 实例,多个 consumer/producer group 共享同一引用。`ConsumerGroupInfo.updateChannel()` 更新 `lastUpdateTimestamp` 时会影响所有 group,导致 `scanNotActiveChannel()` 无法正确过期清理已下线的 group channel。 修复方式:将 `new ClientChannelInfo(...)` 移到循环体内,每个 group 持有独立实例。 ### How Did You Test This Change? 在 `ClientManageProcessorTest` 中新增 `testHeartbeatMultiGroupChannelIndependentExpiry`,验证多 group 心跳场景下各 group 的 `ClientChannelInfo` 互相独立,未续期的 group channel 能被正常过期清理。 -- 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]
