CtrlK
BlogDocsLog inGet started
Tessl Logo
SkillPublic

neo4j-kafka-skill

Configure and operate the Neo4j Connector for Kafka (sink + source) and the native Neo4j CDC API. Covers Cypher/Pattern/CUD sink strategies, CDC-based and query-based source, exactly-once semantics, DLQ error handling, Confluent Cloud managed connector, schema registry (Avro/JSON), and native db.cdc.query cursor-loop patterns (Neo4j 5.13+ Enterprise/Aura BC/VDC). Use when streaming Kafka events into Neo4j, streaming Neo4j changes to Kafka, or querying Neo4j change events without Kafka. Does NOT handle Cypher query authoring — use neo4j-cypher-skill. Does NOT handle bulk CSV/file import — use neo4j-import-skill. Does NOT handle GDS algorithms — use neo4j-gds-skill.

73

Quality

92%

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

82%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 strong, highly actionable reference skill: every section is executable and the decision table, prerequisites, error table, and checklist give it real workflow scaffolding. The main gaps are mild duplication between the body and the CDC reference file, and validation that lives in a checklist rather than inline deployment steps.

Suggestions

Move the 'Event Structure' block and 'Selector Reference' table into references/cdc-api.md (which already advertises 'event structure detail') and replace them in SKILL.md with a one-line pointer and a single minimal example.

Add an inline post-deploy verification step to each connector section (e.g., check the connector task status via the Kafka Connect REST API and confirm one message lands in the target topic/DLQ) instead of relying solely on the closing checklist.

Condense the Prerequisites version notes (connector ≥ 5.5.2, Kafka Connect ≥ 3.x, Neo4j 5.13+ EE/BC/VDC, Java 11+) into a compact two-column table to trim token cost.

DimensionReasoningScore

Conciseness

The body is lean and assumes competence — no space is spent explaining what Kafka or Neo4j is, and configs are shown as compact JSON blocks. Not 5: the full 'Event Structure' block and 'Selector Reference' table duplicate material that references/cdc-api.md explicitly covers ('event structure detail'), so some tokens don't earn their place; not 3: outside that duplication there is no unnecessary explanation.

4 / 5

Actionability

Copy-paste-ready content throughout: complete sink/source connector JSON configs, executable Cypher (EOS constraint, db.cdc.query variants), a working Python cursor-loop, and a Common Errors table mapping error → cause → fix. Not 4: the examples cover the common cases end-to-end, including the Confluent Cloud variant and schema-registry converter settings.

5 / 5

Workflow Clarity

A decision table routes users to the right strategy, prerequisites state version constraints, EOS is a numbered 2-step sequence (constraint then config), and the closing checklist plus error-recovery table provide validation checkpoints for batch/database operations. Not 5: validation is concentrated in a terminal checklist rather than inline checkpoints (e.g., no explicit 'verify connector task is RUNNING / consume one message' step after deploying a config); not 3: the cap does not apply because validation steps are explicitly present.

4 / 5

Progressive Disclosure

Good structure with clearly signaled, one-level-deep references that exist on disk ('[Full connector config reference](references/sink-config.md) — all neo4j.* properties, defaults, types'; '[CDC API patterns](references/cdc-api.md)'), and the bulk config reference is correctly split out. Not 5: the event-structure and selector-reference material inlined in the body belongs in cdc-api.md, which already advertises that content; not 3: the split and navigation are otherwise well done.

4 / 5

Total

17

/

20

Passed

Description

100%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.

The description is a model example: concrete capability enumeration, explicit third-person 'Use when' triggers covering all three use-case entry points, and explicit negative boundaries that disambiguate sibling skills. It is dense but every clause is content-bearing rather than padded, so it earns top marks despite its length.

DimensionReasoningScore

Specificity

Enumerates multiple concrete capabilities — 'Cypher/Pattern/CUD sink strategies, CDC-based and query-based source, exactly-once semantics, DLQ error handling, Confluent Cloud managed connector, schema registry (Avro/JSON), and native db.cdc.query cursor-loop patterns' — with comprehensive coverage of the skill's scope. Not 4: there are no meaningful gaps; every major capability of the connector and CDC API is named explicitly.

5 / 5

Completeness

Explicitly answers both questions: 'what' in the first two capability sentences and 'when' via 'Use when streaming Kafka events into Neo4j, streaming Neo4j changes to Kafka, or querying Neo4j change events without Kafka'. Not 4: the 'when' clause is fully explicit with concrete trigger phrases rather than merely present.

5 / 5

Trigger Term Quality

Natural user phrasings are covered: 'streaming Kafka events into Neo4j', 'streaming Neo4j changes to Kafka', 'querying Neo4j change events without Kafka', plus domain synonyms (Kafka, Neo4j, CDC, Avro, schema registry, DLQ). Not 4: the three 'Use when' clauses capture the distinct ways a user would phrase each intent, and no file extensions are relevant to this domain.

5 / 5

Distinctiveness Conflict Risk

Clear niche (Neo4j-Kafka streaming and CDC) with explicit negative boundaries redirecting to sibling skills: 'Does NOT handle Cypher query authoring — use neo4j-cypher-skill', 'Does NOT handle bulk CSV/file import — use neo4j-import-skill', 'Does NOT handle GDS algorithms — use neo4j-gds-skill'. Not 4: the boundary clauses make overlap with related skills nearly impossible.

5 / 5

Total

20

/

20

Passed

Validation

93%

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

Validation — 15 / 16 Passed

Validation for skill structure

CriteriaDescriptionResult

frontmatter_unknown_keys

Unknown frontmatter key(s) found; consider removing or moving to metadata

Warning

Total

15

/

16

Passed

Repository

neo4j-contrib/neo4j-skills

Path

neo4j-kafka-skill/SKILL.md

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.