Repair Consumer Rebalance Races

    1

    Repair stale consumer ownership, rebalance races, old-generation commits, lease-loss overlap, late callbacks, and ack/commit authority bugs.

    $8.99

    30-day refund guarantee

    Secure checkout via Stripe

    0 installsSecurity scanned

    Works with the AI tools you already use

    CClaude CodeCCursorCCodex CLIGGitHub CopilotGGemini CLI+17 more

    See it in action

    You say

    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.

    Your agent does

    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.

    What you get

    Prevent work overlap during partition rebalancesImplement generation-based fencing for message commitsCoordinate clean shutdown and task cancellation logicAdd deterministic tests for consumer revocation scenarios

    About this skill

    Consumer ownership can change while work is still running. During a Kafka rebalance, queue lease loss, rolling restart, or rapid reassignment, an old handler may finish after ownership moved elsewhere and then commit or ack stale work while a new owner processes the same message.

    This skill maps ownership generations, fences stale handlers and commits, coordinates bounded revoke/shutdown behavior, preserves explicit redelivery/idempotency semantics, and proves the lifecycle with deterministic tests.

    How to install

    Drop the file into your AI Agent. Works with Claude, Cursor, ChatGPT, and 20+ more.

    Reviews

    No reviews yet

    Be one of the first to try it. Every listed skill passes our trust checks below.

    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

    Trust & safety

    Security scanned

    Verified clean today

    Listedtoday

    Frequently Asked Questions