دفّق المعاملات عبر Kafka إلى معالج تدفّق (stream processor) يُجمّع مسبقاً في مخزن OLAP، كي تقرأ لوحات المعلومات تجميعات (rollups) مُحسوبة مسبقاً صغيرة بدل مسح الأحداث الخام. عند ملايين المعاملات/يوم لا تُشغّل SUM() أبداً على الجدول الخام في كل تحميل صفحة — تُجمّع مرّة واحدة، عند الكتابة.
البنية المعمارية
text
Payment svc ──▶ Kafka topic ──▶ Flink/Kafka Streams ──┬─▶ OLAP (ClickHouse/Druid) ◀── Dashboard
(txn events) (buffer,replay) (windowed pre-agg) │ (per-minute rollups) (read)
└─▶ S3/Parquet (raw, replay/audit)
state store ◀──────────┘ (exactly-once checkpoints)