neo4j-kafka-skill
详述 sink/source 策略与精确一次语义，适合流式同步场景
涉及消息系统与 schema 注册表，配置不当可导致数据丢失或重复
配置 Neo4j Kafka Connector 与 CDC 实现数据库与 Kafka 的双向流
要在 Neo4j 与 Kafka 之间做数据流或变更捕获（CDC）时用，能帮你配置 Neo4j Connector for Kafka 的 sink/source 策略、CDC 或基于查询的 source、以及 exactly-once、DLQ、Confluent Cloud 和 Schema Registry（Avro/JSON）的集成。也覆盖 Neo4j 原生的 db.cdc.query 用法，适合需要稳定、可恢复的事件同步和流式工程化场景。
▸ 展开 SKILL.md 英文原文
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.
帮我安装这个 skill：https://raw.githubusercontent.com/neo4j-contrib/neo4j-skills/main/neo4j-kafka-skill/SKILL.mdcurl -fsSL "https://raw.githubusercontent.com/neo4j-contrib/neo4j-skills/main/neo4j-kafka-skill/SKILL.md"# 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` --