Lagerbestand Patch

{
  "type": "record",
  "name": "ArticleStockPatch",
  "namespace": "com.nexoware.connect.events",
  "doc": "Vertragsentwurf: typisierte Teilaenderung fuer Lagerbestand. Nur ChangedFields werden angewandt; null leert nur nullable State-Einheiten. Listen und Unterobjekte sind atomare Ersetzungen mit vollstaendigem Inhalt. Fachliche Freigabe und Regeln gekoppelter Werte sind offen; siehe docs/contracts/articlestock.md.",
  "fields": [
    {
      "name": "EventId",
      "type": {
        "type": "string",
        "logicalType": "uuid"
      },
      "doc": "Beim ersten Enqueue in die Outbox erzeugt; bei Wiederholung identisch."
    },
    {
      "name": "ArticleStockUuid",
      "type": {
        "type": "string",
        "logicalType": "uuid"
      },
      "doc": "Stabile, global eindeutige Identitaet des Bestands-Datensatzes Artikel x Lager (synthetisch, persistiert auf der Quellzeile; zugleich Message-Key - Log-Compaction behaelt je Datensatz den letzten Stand)."
    },
    {
      "name": "Mode",
      "type": {
        "type": "enum",
        "name": "PatchMode",
        "doc": "CHANGE: lokal autorisierte Aenderung, LWW je Einheit nach Kafka-Reihenfolge. INITIAL_LOAD: Erstbefuellung beim Anschluss eines Produkts - setzt eine Einheit nur, wenn sie noch nie geschrieben wurde; ueberschreibt nie einen vorhandenen oder ausdruecklich geleerten Wert. Bewusst ohne Enum-Default: ein unbekannter kuenftiger Modus darf nicht still als CHANGE gelesen werden.",
        "symbols": [
          "CHANGE",
          "INITIAL_LOAD"
        ]
      }
    },
    {
      "name": "ChangedFields",
      "type": {
        "type": "array",
        "items": "string"
      },
      "doc": "Explizite Maske der geaenderten Top-Level-Einheiten; keine Wildcards, Identitaets- oder Auditfelder. Listen und Records werden als Ganzes ersetzt."
    },
    {
      "name": "Data",
      "type": {
        "type": "record",
        "name": "ArticleStockPatchData",
        "doc": "Werte der maskierten Einheiten. null ausserhalb der Maske wird ignoriert; innerhalb der Maske entscheidet die Nullability im State.",
        "fields": [
          {
            "name": "ArticleUuid",
            "type": [
              "null",
              {
                "type": "string",
                "logicalType": "uuid"
              }
            ],
            "doc": "Pflicht-Referenz auf den Artikel-Stamm (article.state). Consumer ohne lokalen Artikel: defer-and-retry. Nur bei Anlage; fixedAfterCreate.",
            "default": null
          },
          {
            "name": "StockUuid",
            "type": [
              "null",
              {
                "type": "string",
                "logicalType": "uuid"
              }
            ],
            "doc": "Pflicht-Referenz auf das Lager (Quelltabelle Warehouses inkl. Hauptlager-Zeile). Kein eigenes Lager-Topic - solange kein Lager-Lesemodell existiert als opakes Referenzfeld speichern. Nur bei Anlage; fixedAfterCreate.",
            "default": null
          },
          {
            "name": "Quantity",
            "type": [
              "null",
              "double"
            ],
            "doc": "Bestandsmenge nach der Buchung (Voll-Snapshot, kein Delta; Quelle ARTIK.Menge bzw. NebenlagerArtikel.Bestand, double).",
            "default": null
          }
        ]
      }
    },
    {
      "name": "ChangedByUuid",
      "type": [
        "null",
        {
          "type": "string",
          "logicalType": "uuid"
        }
      ],
      "doc": "UUID des ausloesenden Mitarbeiters (Employee); null, wenn unbekannt (z. B. automatische Buchung ohne Benutzerkontext).",
      "default": null,
      "references": "Employee"
    },
    {
      "name": "ChangedAt",
      "type": {
        "type": "long",
        "logicalType": "timestamp-millis"
      },
      "doc": "Zeitpunkt der Buchung als UTC-Instant."
    }
  ],
  "aggregate": "ArticleStock",
  "label": "Lagerbestand",
  "topic": "articlestock.patch",
  "key": "ArticleStockUuid",
  "cleanupPolicy": "delete",
  "retentionMs": 2592000000,
  "partitions": 1,
  "writers": [
    "centron",
    "nexoware-erp"
  ],
  "requiredOnCreate": [
    "ArticleUuid",
    "StockUuid",
    "Quantity"
  ],
  "fixedAfterCreate": [
    "ArticleUuid",
    "StockUuid"
  ]
}