You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by GitBox <gi...@apache.org> on 2026/08/26 06:36:49 UTC

[GH] (rocketmq/fix/ignore-corrupted-local-offset): Workflow run "Build and Run Tests by Maven" failed!

The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git/fix/ignore-corrupted-local-offset has failed.
Run started by GitHub user wang-jiahua (triggered by wang-jiahua).

Head commit for run:
dd3318860bd95caf9a75788ebcd85b834abb3738 / wangjiahua.wjh <wa...@alibaba-inc.com>
[ISSUE #10518] Add client config to ignore corrupted local offset files

When ~/.rocketmq_offsets/ files are corrupted (e.g., truncated due to
power loss during persistAll()), readLocalOffsetBak() unconditionally
throws MQClientException, crashing the consumer application.

Fix: Add ClientConfig.localOffsetStoreIgnoreCorrupted (default false).
When true, corrupted offset files are silently skipped with a warning
log, and the consumer starts with an empty offset table (falling back
to CONSUME_FROM_TIMESTAMP or broker-side offset). Default false
preserves existing behavior (fully backward compatible).

Changes:
- ClientConfig: add localOffsetStoreIgnoreCorrupted field + getter/setter
- LocalFileOffsetStore.readLocalOffsetBak(): check config before throwing

Report URL: https://github.com/apache/rocketmq/actions/runs/32936161094

With regards,
GitHub Actions via GitBox