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.
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 use
Skills on Agensi run inside your AI agent. Copy the prompt, paste it into your agent, and it connects to Agensi and installs these skills for you. If a payment is needed, your agent shows it to you first.
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