agentsclimarketplace
Sign in

Kafka consumer semaphore chunking

Skill kjuhwa/skills-hub/skills/backend/kafka-consumer-semaphore-chunking

Bound in-flight async work from a Kafka consumer with `Semaphore(poolSize + queueCapacity - 2)` plus fixed-size chunks; release in `whenComplete` on both success and failure.From its SKILL.md

Install
npx -y skills add kjuhwa/skills-hub --skill kafka-consumer-semaphore-chunking

Assembled from the repository path, not quoted from the project. Check it against their README if it does not work.

One thing to look at

  • 0 stars0 stars. Stars are a popularity signal and not a quality one, but at this level it is likely that nobody has read this closely except its author, and you would be relying on your own review.

SKILL.md

0.5 KB, 6 tokens by cl100k_base, as published. Nobody here has run it

See content.md.

What ships with it: 1 file

1.5 KB alongside SKILL.md

Keep looking

Skills are one crate of 325,949. Ordering is by how many stacks a row turns up in, so the top of any crate is what has actually been picked rather than what has the most stars.