CtrlK
BlogDocsLog inGet started
Tessl Logo

developing-kafka-python-client

Use when the user wants to build a Python Kafka producer or consumer, add Schema Registry to existing Python code, migrate from raw JSON to schema-backed serialization, or scaffold a confluent-kafka-python project for Confluent Cloud, local Docker, or WarpStream. Also use when user wants to optimize Python Kafka client configuration for WarpStream.

71

Quality

89%

Does it follow best practices?

Run evals on this skill

Adds up to 20 points to the overall score

View guide
SecuritybySnyk

Passed

No findings from the security scan

SKILL.md
Quality
Evals
Security

Quality

Content

81%Weight 40%Scale 1-5

Reviews the quality of instructions and guidance provided to agents. Good implementation is clear, handles edge cases, and produces reliable results.

A highly actionable, well-sequenced skill body with real validation feedback loops and a solid one-level reference bundle. Its main weakness is token efficiency: several critical warnings are duplicated 3-4 times and large boilerplate blocks are inlined rather than referenced.

Suggestions

State each critical warning (WarpStream SR Avro exception, kwargs-only serializer construction, AIOProducer headers limitation) once in a single 'Common pitfalls' section and reference it from the other sections instead of repeating it verbatim 3-4 times.

Collapse the three near-identical requirements.txt blocks into one block plus a one-line note to swap the extra (e.g., `confluent-kafka[avro,...]` vs `confluent-kafka[json,...]`), or move them into the readme template reference.

Trim the duplicated confirmation-gate prose by merging the HARD-GATE block and the Step 1 'Mandatory confirmation gate' into one normative statement, and move the full JSON/Avro example schemas into the schema-generation-rules reference.

DimensionReasoningScore

Conciseness

Most content is dense, non-obvious, and earns its place (constructor-signature differences, the fetch.max.bytes >= message.max.bytes constraint, listener-name pitfalls), but the same warnings are repeated three to four times each — the WarpStream Avro exception appears in Step 1, the mistakes table, Core Principle 2, and the schemas section; the kwargs/TypeError warning and the AIOProducer headers NotImplementedError warning are each restated in 3+ places; the confirmation gate is specified three times (HARD-GATE, Step 1 mandatory gate, Step 1b). This repetition is noticeably more than 'some' unnecessary padding, but the bulk is genuinely useful, placing it between the 2 and 3 anchors at 3.

3 / 5

Actionability

Guidance is fully executable: exact project file tree, complete .env.example blocks per environment, full requirements.txt contents, exact docker commands (e.g., `docker compose exec kafka kafka-topics --create --topic demo-topic --bootstrap-server localhost:29092`), concrete test properties, and named copy-from reference templates for every code path. The common cases are covered copy-paste ready.

5 / 5

Workflow Clarity

A clear Step 1 → 1b → 2 → 3 sequence with an explicit decision flowchart, numbered requirement questions with defaults and skip rules, mandatory confirmation checkpoints (recap + wait for reply), connectivity verification before running, and a validation feedback loop — 'run `pytest tests/`... If any test fails, fix the generated code (not the tests) until they pass'.

5 / 5

Progressive Disclosure

All 14 referenced paths (warpstream-optimization.md, producer/consumer templates, schema-generation-rules.md, multi-event-guide.md, etc.) are real one-level-deep bundle files, clearly signaled per topic. However, the ~440-line body inlines substantial content that could live in references — three near-identical full requirements.txt blocks and complete JSON/Avro schema examples — leaving minor organization gaps versus the ideal split.

4 / 5

Total

17

/

20

Passed

Description

92%Weight 40%Scale 1-5

Based on the skill's description, can an agent find and select it at the right time? Clear, specific descriptions lead to better discovery.

A strong description: concrete, comprehensive capabilities paired with explicit and specific 'Use when' trigger phrases, all in third person. Only minor headroom in keyword synonyms.

DimensionReasoningScore

Specificity

The description lists multiple concrete actions — "build a Python Kafka producer or consumer", "add Schema Registry to existing Python code", "migrate from raw JSON to schema-backed serialization", "scaffold a confluent-kafka-python project" — and names all three target environments. Coverage of the skill's capabilities is comprehensive with no vague filler.

5 / 5

Completeness

Both 'what' and 'when' are explicitly and concretely answered: two explicit "Use when..." clauses name the specific scenarios (build, integrate Schema Registry, migrate from raw JSON, scaffold, optimize for WarpStream). This matches the top anchor's structure of concrete capabilities paired with concrete trigger phrases.

5 / 5

Trigger Term Quality

Natural keywords are strong — "Kafka producer", "consumer", "Schema Registry", "confluent-kafka-python", "Confluent Cloud", "local Docker", "WarpStream", "raw JSON" — matching phrases users would actually say. A few plausible variations (e.g., "librdkafka", "consumer group", "streaming") are missing, so it falls just short of the comprehensive anchor.

4 / 5

Distinctiveness Conflict Risk

It occupies a clear niche — confluent-kafka-python client development with named environments (Confluent Cloud, WarpStream, local Docker) — so triggers are distinct and unlikely to fire for unrelated Kafka/Python skills. No generic language that would overlap broadly.

5 / 5

Total

19

/

20

Passed

Validation

100%

Checks the skill against the spec for correct structure and formatting. All validation checks must pass before discovery and implementation can be scored.

Validation — 16 / 16 Passed

Validation for skill structure

No warnings or errors.

Repository
confluentinc/agent-skills
Reviewed

Table of Contents

Is this your skill?

If you maintain this skill, you can claim it as your own. Once claimed, you can manage eval scenarios, bundle related skills, attach documentation or rules, and ensure cross-agent compatibility.