The GitHub Actions job "CI" on 
rocketmq-dashboard.git/fix/offset-illegal-breaks-message-scan-1353 has failed.
Run started by GitHub user tju-yxq (triggered by tju-yxq).

Head commit for run:
79d8e5e7c0b2ef5bed38b45af260dcfdb0437ac9 / Yxq <[email protected]>
[ISSUE #1353] Handle OFFSET_ILLEGAL in message and DLQ pull scans

When PullResult returns OFFSET_ILLEGAL, the scan loop was breaking
out of the current queue, silently dropping all remaining messages
in that queue. The broker returns a corrected offset in
nextBeginOffset that should be retried.

This fix:
- Adds OFFSET_ILLEGAL handling to both queryByTopic() and
  collectDeadLetters() with continue instead of break
- Adds a max-retry guard (3 consecutive OFFSET_ILLEGAL per queue)
  to prevent infinite loops
- Resets the counter on successful FOUND pulls
- Preserves existing NO_NEW_MSG/NO_MATCHED_MSG break behavior

Fixes #1353

Report URL: 
https://github.com/apache/rocketmq-dashboard/actions/runs/31353357545

With regards,
GitHub Actions via GitBox

Reply via email to