neo4j-kafka-skill SKILL.md skillA

neo4j-kafka-skill from neo4j-contrib/neo4j-skills is an agent skill: a SKILL.md folder an AI agent loads when a task calls for it.

Install it, pinned
mdr add neo4j-contrib/neo4j-skills/neo4j-kafka-skill@v1.0.4

Pins v1.0.4 in mdr.lock. Pin the fingerprint instead.

Audit grade
A, 17 of 17 checks passed
Kind
SKILL.md skill
Repository
neo4j-contrib/neo4j-skills
Path
neo4j-kafka-skill/SKILL.md
Versions recorded
5
Latest version
v1.0.4, committed Aug 25, 2026
First version recorded
May 29, 2026
Size
14,986 bytes
Repository stars
121
License
MIT

Configure and operate the Neo4j Connector for Kafka (sink + source) and the.

Collected from public GitHub. Every version is saved exactly as it was and never changes. Install it at an exact version with the mdr tool, and every file is checked before it reaches your agent. The main file is checked against the SHA-256 fingerprint recorded here, and the others against the fingerprints GitHub keeps for its source commit. The automatic checks below grade the latest version, and the same checks always give the same file the same grade.

What the file says

# Neo4j Kafka Skill

## When to Use

- Writing Kafka events into Neo4j (sink connector — Cypher, Pattern, CDC, CUD strategies)
- Streaming Neo4j changes to Kafka topics (source connector — CDC or query-based)
- Querying Neo4j change events natively without Kafka (`db.cdc.query`)
- Configuring Confluent Cloud managed Neo4j sink connector
- Setting up schema registry (Avro/JSON Schema) for typed Kafka messages
- Enabling exactly-once semantics or dead-letter queue on sink

## When NOT to Use

- **Cypher query authoring** → `neo4j-cypher-skill`
- **Bulk CSV/JSON file import** → `neo4j-import-skill`
- **GDS algorithms** → `neo4j-gds-skill`
- **Live app write patterns** → `neo4j-cypher-skill`

---

## Decision Table — Which connector strategy?

| Use case | Strategy |
|---|---|
| Custom transformation of Kafka payload → graph | Sink: **Cypher** |
| Mirror another Neo4j CDC source | Sink: **CDC** (schema or source-id sub-strategy) |
| Map Kafka JSON fields to graph nodes/rels with no code | Sink: **Pattern** |
| Consume pre-formatted CUD JSON messages | Sink: **CUD** |
| Stream all Neo4j changes to Kafka (real-time) | Source: **CDC** (Neo4j 5.13+ EE/Aura BC/VDC) |
…

Read the whole file at its exact version.

How to install

The exact contents, by fingerprint
mdr add neo4j-contrib/neo4j-skills/neo4j-kafka-skill@sha256:bbec729a4ac5ba35

The line at the top of this page pins the label v1.0.4, which is what most people want. This one pins the sha256 fingerprint of the contents instead, so it survives a label being moved. Either way the exact version is written to mdr.lock, and mdr install downloads and checks those contents again, so it installs them exactly or stops with an error.

Badge

mdr badge

[![mdr](https://markdownregistry.com/badge/art_jpwg6haxj6nmjsq6.svg)](https://markdownregistry.com/a/art_jpwg6haxj6nmjsq6)

2 badge image fetches in 30 days. What the badge shows.

Versions

The registry has recorded 5 versions of this file, between May 29, 2026 and Aug 25, 2026, about one every 22 days.

versioncommittedcommitsizeaudit
v1.0.4 latest2026-08-25 a9a5e78 14,986 BA view · diff
v1.0.32026-08-14 5e29ed4 14,862 BA view · diff
v1.0.22026-08-13 c3e91d0 14,862 BA view · diff
v1.0.12026-07-09 bbb6eb1 14,862 BA view · diff
v1.0.12026-05-29 7427d7a 14,794 BA view

Audit of the latest version

A  17 of 17 checks passed. Fixed automatic checks with no AI involved, so the same checks give the same answer every run.
  • pass: Frontmatter block present
  • pass: Frontmatter declares a name
  • pass: Frontmatter declares a description
  • pass: Size between 200 bytes and 200 KB (14986 bytes)
  • pass: No zero-width or bidi control characters
  • pass: No instruction hidden inside an HTML comment
  • pass: No link to an exfiltration or paste host
  • pass: No credential-shaped string
  • pass: No instruction to send local credentials anywhere
  • pass: No text hidden with inline styles
  • pass: No prompt-injection phrasing
  • pass: No curl or wget piped into a shell
  • pass: No recursive delete of root, home or parent
  • pass: No instruction to read or print local credentials
  • pass: No base64 blob over 200 characters
  • pass: No link to a raw IP address
  • pass: No script tag

Source

GitHub

neo4j-contrib/neo4j-skills · 121 stars · license MIT · pushed 2026-11-02 · branch main

API

GET https://markdownregistry.com/api/v1/artifacts/art_jpwg6haxj6nmjsq6
GET https://markdownregistry.com/api/v1/resolve?ref=neo4j-contrib/neo4j-skills/neo4j-kafka-skill
GET https://markdownregistry.com/api/v1/blob/bbec729a4ac5ba350c19866436c0e1ee857913b01f7fdd4602fd4c1eb977a4d8

Your AI assistant does the legwork. You hear about the deals worth your word. Hand yours the standing instructions at modelranch.com and it joins the network that reads files like this one.

Guides: the SKILL.md format and its required fields · what to check before you install a skill · how to pin a skill to an exact version · where to find agent skills · keeping a team on the same skills · which agent file does what.

More from neo4j-contrib/neo4j-skills

AGENTS.md AGENTS.md file
neo4j-contrib/neo4j-skills · AGENTS.md
git:20260922.a678fef · audit A · 121 stars
neo4j-agent-memory-skill SKILL.md skill
neo4j-contrib/neo4j-skills · neo4j-agent-memory-skill/SKILL.md · Authoritative reference for the neo4j-agent-memory Python package — a graph-native memory system for AI agents built on…
v1.0.9 · audit A · 121 stars
neo4j-aura-agent-skill SKILL.md skill
neo4j-contrib/neo4j-skills · neo4j-aura-agent-skill/SKILL.md · Manages Neo4j Aura Agents via the v2beta1 REST API — create, list, get, update, delete,
v1.1.0 · audit B · 121 stars
neo4j-aura-graph-analytics-skill SKILL.md skill
neo4j-contrib/neo4j-skills · neo4j-aura-graph-analytics-skill/SKILL.md · Serverless Aura Graph Analytics (AGA) GDS Sessions — covers GdsSessions,
v1.0.13 · audit A · 121 stars
neo4j-aura-provisioning-skill SKILL.md skill
neo4j-contrib/neo4j-skills · neo4j-aura-provisioning-skill/SKILL.md · Provisions and manages Neo4j Aura instances via CLI (aura-cli v1.7+) or REST API.
v1.0.5 · audit B · 121 stars
neo4j-cli-tools-skill SKILL.md skill
neo4j-contrib/neo4j-skills · neo4j-cli-tools-skill/SKILL.md · Use when working with Neo4j command-line tools — neo4j-cli (modern unified
v1.0.15 · audit B · 121 stars
neo4j-cypher-skill SKILL.md skill
neo4j-contrib/neo4j-skills · neo4j-cypher-skill/SKILL.md · Generates, optimizes, and validates Cypher 25 queries for Neo4j 2025.x and 2026.x.
v1.0.31 · audit A · 121 stars
neo4j-document-import-skill SKILL.md skill
neo4j-contrib/neo4j-skills · neo4j-document-import-skill/SKILL.md · Ingests unstructured and semi-structured documents into Neo4j as a knowledge graph.
v1.0.7 · audit A · 121 stars
neo4j-driver-dotnet-skill SKILL.md skill
neo4j-contrib/neo4j-skills · neo4j-driver-dotnet-skill/SKILL.md · Neo4j .NET Driver v6 — IDriver lifecycle, DI registration (singleton), ExecutableQuery
v1.0.8 · audit A · 121 stars
neo4j-driver-go-skill SKILL.md skill
neo4j-contrib/neo4j-skills · neo4j-driver-go-skill/SKILL.md · Covers the Neo4j Go Driver v6 — driver lifecycle, ExecuteQuery, managed and
v1.0.8 · audit A · 121 stars
neo4j-driver-java-skill SKILL.md skill
neo4j-contrib/neo4j-skills · neo4j-driver-java-skill/SKILL.md · Neo4j Java Driver v6 — driver lifecycle, Maven/Gradle setup, executableQuery,
v1.0.12 · audit A · 121 stars
neo4j-driver-javascript-skill SKILL.md skill
neo4j-contrib/neo4j-skills · neo4j-driver-javascript-skill/SKILL.md · Neo4j JavaScript/TypeScript Driver v6 — driver lifecycle, executeQuery,
v1.0.7 · audit A · 121 stars

Every file in neo4j-contrib/neo4j-skills

Browse by kind, by grade A, or by owner.