- sync_reset() 添加 20 秒等待时间,确保 consumer group 变成 inactive - 添加重试逻辑(最多 3 次,每次间隔 10 秒) - 使用 grep NEW-OFFSET 检测 offset reset 是否成功 Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> |
||
|---|---|---|
| .. | ||
| settings.local.json | ||
- sync_reset() 添加 20 秒等待时间,确保 consumer group 变成 inactive - 添加重试逻辑(最多 3 次,每次间隔 10 秒) - 使用 grep NEW-OFFSET 检测 offset reset 是否成功 Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> |
||
|---|---|---|
| .. | ||
| settings.local.json | ||