feat(eap): Add EAP mutations topic (#333)

* add eap mutations topic

* style(lint): Auto commit lint changes

* style(lint): Auto commit lint changes

* fix incorrect names

* style(lint): Auto commit lint changes

* style(lint): Auto commit lint changes

* add codeowner

* revert reformat

* fix codeowners

* fix schema

---------

Co-authored-by: getsantry[bot] <66042841+getsantry[bot]@users.noreply.github.com>

Author: ayirr7

CODEOWNERS

@@ -38,6 +38,7 @@
 /topics/snuba-metrics-summaries.yaml                           @getsentry/owners-snuba @getsentry/profiling
 /topics/snuba-profile-chunks.yaml                              @getsentry/owners-snuba @getsentry/profiling
 /topics/snuba-spans.yaml                                       @getsentry/owners-snuba @getsentry/performance
+/topics/snuba-eap-mutations.yaml                               @getsentry/owners-snuba
 
 # Topics produced by Sentry
 /topics/buffered-segments.yaml                                 @getsentry/owners-snuba @getsentry/performance

examples/snuba-eap-mutations/mutation-1.json

@@ -0,0 +1,16 @@
+{
+  "filter": {
+    "organization_id": 1500,
+    "_sort_timestamp": 150,
+    "trace_id": "deadbeefdeadbeefdeadbeefdeadbeef",
+    "span_id": "deadbeefdeadbeef"
+  },
+  "update": {
+    "attr_str": {
+      "a": "b"
+    },
+    "attr_num": {
+      "c": 147174124.3
+    }
+  }
+}

schemas/snuba-eap-mutations.v1.schema.json

@@ -0,0 +1,60 @@
+{
+  "$schema": "http://json-schema.org/draft-07/schema#",
+  "$ref": "#/definitions/Main",
+  "definitions": {
+    "Main": {
+      "type": "object",
+      "title": "eap_mutation",
+      "properties": {
+        "filter": {
+          "type": "object",
+          "additionalProperties": false,
+          "properties": {
+            "organization_id": {
+              "$ref": "#/definitions/UInt"
+            },
+            "_sort_timestamp": {
+              "$ref": "#/definitions/UInt"
+            },
+            "trace_id": {
+              "$ref": "#/definitions/UUID",
+              "description": "The trace ID is a unique identifier for a trace. It is a 16 byte hexadecimal string."
+            },
+            "span_id": {
+              "type": "string",
+              "description": "The span ID is a unique identifier for a span within a trace. It is an 8 byte hexadecimal string."
+            }
+          }
+        },
+        "update": {
+          "type": "object",
+          "additionalProperties": false,
+          "properties": {
+            "attr_str": {
+              "type": "object",
+              "additionalProperties": {
+                "type": "string"
+              }
+            },
+            "attr_num": {
+              "type": "object",
+              "additionalProperties": {
+                "type": "number"
+              }
+            }
+          }
+        }
+      },
+      "additionalProperties": false
+    },
+    "UInt": {
+      "type": "integer",
+      "minimum": 0
+    },
+    "UUID": {
+      "type": "string",
+      "minLength": 32,
+      "maxLength": 36
+    }
+  }
+}

topics/snuba-eap-mutations.yaml

@@ -0,0 +1,18 @@
+description: Mutations updates for spans
+services:
+  producers:
+    - getsentry/sentry
+  consumers:
+    - getsentry/snuba
+schemas:
+  - version: 1
+    compatibility_mode: none
+    type: json
+    resource: snuba-eap-mutations.v1.schema.json
+    examples:
+      - snuba-eap-mutations/
+topic_creation_config:
+  compression.type: lz4
+  retention.ms: "86400000"
+  max.message.bytes: "10000000"
+  message.timestamp.type: LogAppendTime