Skip to content

feat: pass graph node ID (neo4j) to CDC node-related events #7

@metacoma

Description

@metacoma

kafka CDC event

{
  "meta": {
    "timestamp": 1739884169128,
    "username": "neo4j",
    "txId": 39,
    "txEventId": 0,
    "txEventsCount": 1,
    "operation": "created",
    "source": {
      "hostname": "pink-neo4j-0"
    }
  },
  "payload": {
    "id": "0",
    "before": null,
    "after": {
      "properties": {
        "atime": 0,
        "traceparent": "00-dcc72e8214ce058f763f295f2f54ebb4-2e5603ac46225456-01",
        "type": "org.mindwm.v1.graph.node.user",
        "username": "bebebeka"
      },
      "labels": [
        "User"
      ]
    },
    "type": "node"
  },
  "schema": {
    "properties": {
      "atime": "Long",
      "traceparent": "String",
      "type": "String",
      "username": "String"
    },
    "constraints": []
  }
}

MindWM node create event

{
  "specversion": "1.0",
  "id": "e62fc919de2c4e87b5a05f9b760e4a28",
  "source": "org.mindwm.context.pink.knfunc.kafka_cdc",
  "type": "org.mindwm.v1.graph.created",
  "subject": "org.mindwm.context.pink.graph.node",
  "datacontenttype": "application/json",
  "data": {
    "type": "org.mindwm.v1.graph.created",
    "obj": {
      "traceparent": "00-dcc72e8214ce058f763f295f2f54ebb4-2e5603ac46225456-01",
      "tracestate": null,
      "username": "bebebeka",
      "type": "org.mindwm.v1.graph.node.user",
      "created": null,
      "merged": null,
      "atime": 0
    }
  },
  "knativearrivaltime": "2025-02-18T13:09:33.258090258Z",
  "knativebrokerttl": "255",
  "traceparent": "00-23c8a6c88e8830f43b692aaa021c09e2-a3db90193f23cfdd-01",
  "tracestate": ""
}

Metadata

Metadata

Assignees

Labels

enhancementNew feature or request

Projects

Status

No status

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions