Skills
.Work. You
Rest

neo4j-kafka-skill

Official

Stream Neo4j and Kafka changes reliably

Software Engineering#streaming#kafka#connector#neo4j#cdc#dead-letter-queue#exactly-once
Authorneo4j-contrib
Version1.0.0
Installs0

System Documentation

What problem does it solve?

This Skill helps you configure and operate Neo4j’s Kafka integrations so graph data can be ingested from Kafka topics and graph changes can be streamed out with correct semantics and resilient error handling.

Core Features & Use Cases

  • Kafka sink strategies for Neo4j writes: supports Cypher, Pattern, CDC (schema/source-id), and CUD message formats to transform or apply streaming events to a Neo4j graph.
  • Reliable streaming with EOS and DLQ: enables exactly-once semantics using offset tracking constraints and configures dead-letter queues for production-grade failure handling.
  • Kafka source strategies and native change queries: streams Neo4j changes to Kafka via CDC-based (Neo4j 5.13+) or query-based approaches, and also supports consuming change events without Kafka through the native db.cdc.query API.

Quick Start

Install and configure the Neo4j Kafka Connect connector for your target Kafka topics, then choose a sink strategy (Cypher/Pattern/CDC/CUD) or a source strategy (CDC/Query) based on whether you are writing to Neo4j or streaming Neo4j changes out.

Dependency Matrix

Required Modules

None required

Components

references

💻 Claude Code Installation

Recommended: Let Claude install automatically. Simply copy and paste the text below to Claude Code.

Please help me install this Skill:
Name: neo4j-kafka-skill
Download link: https://github.com/neo4j-contrib/neo4j-skills/archive/main.zip#neo4j-kafka-skill

Please download this .zip file, extract it, and install it in the .claude/skills/ directory.
View Source Repository

Agent Skills Search Helper

Install a tiny helper to your Agent, search and equip skill from 471,000+ vetted skills library on demand.