如何基于Debezium事件在Neo4j Kafka Connect中条件删除节点？

核心问题 #

Debezium发送的删除事件（op='d'）中，event.after字段为空，只有event.before包含被删除记录的原始数据。你之前的语句用event.after.id匹配节点，自然找不到目标节点，导致删除操作无效。

正确的Cypher同步语句 #

针对Debezium的三种操作类型，分别用event.after（创建/更新）和event.before（删除）来定位节点，结合FOREACH实现条件执行：

-- 处理创建/更新事件（op='c'/'u'）
FOREACH (ignoreMe IN CASE WHEN event.op IN ['c', 'u'] THEN [1] ELSE [] END |
  MERGE (p:DemoTable {id: event.after.id})
  SET p.message = event.after.message,
      p.last_changed = event.ts_ms
)
-- 处理删除事件（op='d'）
WITH event
FOREACH (ignoreMe IN CASE WHEN event.op = 'd' THEN [1] ELSE [] END |
  MATCH (p:DemoTable {id: event.before.id})
  DELETE p
)

关键说明 #

1. 删除事件用event.before.id：必须通过event.before获取被删除记录的ID，这是Debezium删除事件的标准结构。
2. 拆分逻辑更清晰：将创建/更新和删除逻辑明确拆分，避免因字段不存在导致的匹配失败。
3. 兼容FOREACH限制：由于Cypher不允许在FOREACH内使用MATCH，所以先通过WITH传递event，再单独执行删除分支的MATCH+DELETE，确保语法合规。

额外验证建议 #

• 查看Kafka中的删除事件消息，确认event.before字段是否包含正确的ID值。
• 单独执行删除分支的Cypher语句（替换event.before.id为实际ID），验证节点是否能正常删除。

内容的提问来源于stack exchange，提问作者Jan Katins