{
  "id": "skill-area:kafka-stream-processing",
  "_kind": "SkillArea",
  "_file": "domain/skill-areas/kafka-stream-processing.yaml",
  "_cluster": "domain",
  "attributes": {
    "displayName": "Kafka Stream Processing",
    "description": "Building real-time data pipelines on Apache Kafka: Kafka Streams DSL,\nksqlDB, exactly-once semantics, stateful aggregations, windowing,\nconsumer-group rebalancing, and schema management with Schema Registry.\n",
    "domains": [
      "domain:data-engineering",
      "topic:event-driven-architecture"
    ],
    "requiresLanguages": [
      "language:java",
      "language:scala"
    ],
    "requiresStackParts": [
      "stack-part:message-queue",
      "stack-part:event-bus"
    ],
    "expertiseLevels": [
      "intermediate",
      "expert",
      "authoritative"
    ]
  },
  "outgoingEdges": [
    {
      "from": "skill-area:kafka-stream-processing",
      "to": "domain:data-engineering",
      "kind": "applies_to",
      "attributes": {
        "confidence": "primary"
      }
    },
    {
      "from": "skill-area:kafka-stream-processing",
      "to": "specialization:redis-ops",
      "kind": "applies_to",
      "attributes": {
        "confidence": "secondary"
      }
    },
    {
      "from": "skill-area:kafka-stream-processing",
      "to": "topic:event-driven-architecture",
      "kind": "applies_to",
      "attributes": {
        "confidence": "secondary"
      }
    },
    {
      "from": "skill-area:kafka-stream-processing",
      "to": "stack-part:message-queue",
      "kind": "uses_stack_part"
    },
    {
      "from": "skill-area:kafka-stream-processing",
      "to": "stack-part:event-bus",
      "kind": "uses_stack_part"
    },
    {
      "from": "skill-area:kafka-stream-processing",
      "to": "language:java",
      "kind": "uses_language"
    },
    {
      "from": "skill-area:kafka-stream-processing",
      "to": "language:java",
      "kind": "uses_language",
      "attributes": {}
    },
    {
      "from": "skill-area:kafka-stream-processing",
      "to": "language:scala",
      "kind": "uses_language",
      "attributes": {}
    }
  ],
  "incomingEdges": [
    {
      "from": "language:java",
      "to": "skill-area:kafka-stream-processing",
      "kind": "used_by_skill_area",
      "attributes": {}
    },
    {
      "from": "language:scala",
      "to": "skill-area:kafka-stream-processing",
      "kind": "used_by_skill_area",
      "attributes": {}
    },
    {
      "from": "skill-area:stream-processing-design",
      "to": "skill-area:kafka-stream-processing",
      "kind": "prerequisite_for_learning",
      "attributes": {
        "strength": "helpful"
      }
    },
    {
      "from": "skill-area:backend-async-processing",
      "to": "skill-area:kafka-stream-processing",
      "kind": "prerequisite_for_learning",
      "attributes": {
        "strength": "recommended"
      }
    },
    {
      "from": "stack-part:event-bus",
      "to": "skill-area:kafka-stream-processing",
      "kind": "stack_part_used_by",
      "attributes": {}
    },
    {
      "from": "stack-part:message-queue",
      "to": "skill-area:kafka-stream-processing",
      "kind": "stack_part_used_by",
      "attributes": {}
    },
    {
      "from": "stack-profile:stream-processing",
      "to": "skill-area:kafka-stream-processing",
      "kind": "requires_skill_area"
    },
    {
      "from": "stack-profile:adtech-real-time-bidding",
      "to": "skill-area:kafka-stream-processing",
      "kind": "requires_skill_area"
    },
    {
      "from": "stack-profile:cqrs-read-model",
      "to": "skill-area:kafka-stream-processing",
      "kind": "requires_skill_area"
    },
    {
      "from": "stack-profile:real-time-analytics-stack",
      "to": "skill-area:kafka-stream-processing",
      "kind": "requires_skill_area"
    },
    {
      "from": "stack-profile:event-driven-stack",
      "to": "skill-area:kafka-stream-processing",
      "kind": "requires_skill_area"
    },
    {
      "from": "tool-server:mcp-kafka",
      "to": "skill-area:kafka-stream-processing",
      "kind": "integrates_with",
      "attributes": {}
    },
    {
      "from": "lib-skill:data-engineering-analytics--stream-processing-windowing-designer",
      "to": "skill-area:kafka-stream-processing",
      "kind": "lib_requires_skill_area",
      "attributes": {
        "weight": 0.7
      }
    },
    {
      "from": "role:trading-systems-engineer",
      "to": "skill-area:kafka-stream-processing",
      "kind": "requires_expertise",
      "attributes": {}
    },
    {
      "from": "role:streaming-engineer",
      "to": "skill-area:kafka-stream-processing",
      "kind": "requires_expertise",
      "attributes": {}
    },
    {
      "from": "workflow:precision-agriculture-data-pipeline",
      "to": "skill-area:kafka-stream-processing",
      "kind": "requires_skill_area",
      "attributes": {}
    },
    {
      "from": "workflow:event-driven-architecture-review",
      "to": "skill-area:kafka-stream-processing",
      "kind": "requires_skill_area",
      "attributes": {}
    },
    {
      "from": "workflow:real-time-streaming-health-check",
      "to": "skill-area:kafka-stream-processing",
      "kind": "requires_skill_area",
      "attributes": {}
    },
    {
      "from": "workflow:cdc-pipeline-validation",
      "to": "skill-area:kafka-stream-processing",
      "kind": "requires_skill_area",
      "attributes": {}
    },
    {
      "from": "workflow:data-pipeline-monitoring",
      "to": "skill-area:kafka-stream-processing",
      "kind": "requires_skill_area",
      "attributes": {}
    },
    {
      "from": "workflow:grid-stability-monitoring",
      "to": "skill-area:kafka-stream-processing",
      "kind": "requires_skill_area",
      "attributes": {}
    },
    {
      "from": "workflow:game-analytics-instrumentation",
      "to": "skill-area:kafka-stream-processing",
      "kind": "requires_skill_area",
      "attributes": {}
    },
    {
      "from": "workflow:content-release-pipeline",
      "to": "skill-area:kafka-stream-processing",
      "kind": "requires_skill_area",
      "attributes": {}
    },
    {
      "from": "workflow:feature-store-management",
      "to": "skill-area:kafka-stream-processing",
      "kind": "requires_skill_area",
      "attributes": {}
    },
    {
      "from": "workflow:inventory-replenishment-cycle",
      "to": "skill-area:kafka-stream-processing",
      "kind": "requires_skill_area",
      "attributes": {}
    },
    {
      "from": "workflow:transaction-reporting-cycle",
      "to": "skill-area:kafka-stream-processing",
      "kind": "requires_skill_area",
      "attributes": {}
    },
    {
      "from": "workflow:market-data-feed-validation",
      "to": "skill-area:kafka-stream-processing",
      "kind": "requires_skill_area",
      "attributes": {}
    },
    {
      "from": "workflow:fleet-maintenance-scheduling",
      "to": "skill-area:kafka-stream-processing",
      "kind": "requires_skill_area",
      "attributes": {}
    },
    {
      "from": "workflow:data-pipeline-monitoring",
      "to": "skill-area:kafka-stream-processing",
      "kind": "requires_skill_area",
      "attributes": {}
    }
  ]
}