Event Consumer & Completion Safety
Make event-driven work safe across consumer rebalances, duplicate completion, lost wakeups, permit ownership, breaker races, outbox delivery, queue retries, and orphan cleanup. This bundle repairs coordination failures that appear only during reassignment, timeout, retry, cancellation, or competing completion paths. Use it when asynchronous work can be processed twice, abandoned, acknowledged too early, or left permanently owned by a dead worker.
Works with every agent that reads SKILL.md — Claude Code, Cursor, Codex CLI, Gemini CLI, GitHub Copilot, Windsurf, OpenClaw, and more.
One payment, lifetime access. 8 skills unlock instantly in your library.
30-day refund guarantee
Instant unlock in your library
Free updates from the creator
What's included
8 skills
Repair stale consumer ownership, rebalance races, old-generation commits, lease-loss overlap, late callbacks, and ack/commit authority bugs.
Repair double completion, duplicate callbacks, timeout/cancel races, stale retry callbacks, duplicate response writes, and cleanup running twice.
Repair lost wakeups in condition variables, worker queues, shutdown gates, wait/notify loops, and hand-built events.
Repair semaphore permit leaks and over-release bugs across exceptions, cancellation, timeouts, task submission, and shutdown.
Repair circuit-breaker state races across closed, open, and half-open transitions without changing resilience policy.
Repair systems that commit database changes but lose or duplicate the events that should follow.
Repair background-job retry drift in a repository using Cursor.
Safely detect, verify, quarantine, and clean up orphaned cloud resources after failed provisioning, deletions, or database drift.
See it in action
Repair Consumer Rebalance Races
Example session with this skill installed
Our Java/Kafka order worker uses cooperative rebalancing. A handler may take 20-40 seconds. On revoke we update assignedPartitions but do not fence running tasks. Those tasks can finish after the partition moves, then try to commit offsets from the old generation. We see CommitFailedException during deploys and occasional duplicate downstream calls. Repair locally with deterministic rebalance callbacks and fake downstream effects. Preserve broker/session settings. Do not connect to production Kafka or claim exactly-once.
- Read your context and instructions
- Compiled the repair consumer rebalance
Rebalance race found. Revoked work continues without ownership generation fencing and can attempt stale commits after reassignment. The repair tags in-flight work with ownership generations, fences stale commit paths, coordinates bounded revoke handling, and tests revoke-during-processing deterministically.
How to install
Works the same in every agent - Claude, Cursor, Codex, Copilot and 20+ more.
- 1
Download the ZIP
Free skills download straight away. Paid skills unlock right after purchase.
- 2
Unzip into your skills folder
Every agent reads skills from one folder on your machine. Drop the unzipped folder in there.
- 3
Ask your agent to use it
Restart the agent if it was already running. It picks the skill up automatically - no config needed.
Skills folder by agent
Click the path to copy it. Create the folder if it does not exist yet.
Reviews
No reviews yet
Be one of the first to try it. Every skill in this bundle passes our trust checks.
Security scanned
Passed our 8-point scan before listing
Fresh listing
Recently published to Agensi
30-day refund
Not a fit? Get your money back