kafka-adapter-telemetry — System Architecture

kafka-adapter-telemetry — System Architecture An architecture diagram generated by Archify. Mission-Control Dashboard · Vite + React · served at :8082 · Architecture component · SSE + ECharts Mission-Control Dashboard Vite + React · served at :8082 SSE + ECharts adapter-gateway · REST ingest · :8081 · Architecture component · seeded simulator adapter-gateway REST ingest · :8081 seeded simulator adapter.telemetry.v1 · keyed by adapterId · Kafka · 3 partitions adapter.telemetry.v1 keyed by adapterId 3 partitions telemetry-hub · consumer + read API · :8082 · Architecture component telemetry-hub consumer + read API · :8082 Oracle Free · Flyway · 3 tables · Architecture component · primary-key idempotency Oracle Free Flyway · 3 tables primary-key idempotency adapter.alerts.v1 · published alerts · Kafka adapter.alerts.v1 published alerts adapter.telemetry.v1.dlt · dead letters · Kafka adapter.telemetry.v1.dlt dead letters POST /simulate (CORS :8082) String JSON consume idempotent upsert AlertEvent malformed JSON / retries exhausted SSE + read API Kafka Legend Frontend Backend Database Message bus

Ingest

  • • REST ingest on :8081; a seeded TrafficGenerator drives the profiles
  • • Browser control is CORS-allowlisted to the dashboard origin

Pipeline

  • • Two retries, then the record is routed to the DLT
  • • The Oracle primary key is the idempotency referee

Observability

  • • TelemetryTap fans decisions into in-memory metrics
  • • SSE plus snapshot feed the dashboard; DltObserver counts dead letters