The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git/fix/ignore-corrupted-local-offset has succeeded. Run started by GitHub user wang-jiahua (triggered by wang-jiahua).
Head commit for run: 72b8ae591d08326e375f0f98c4ec75f1c255d896 / wangjiahua.wjh <[email protected]> [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/31770950571 With regards, GitHub Actions via GitBox
