-
Notifications
You must be signed in to change notification settings - Fork 1
Architecture
Qichao Chu edited this page Apr 9, 2026
·
1 revision
┌─────────────────────────────────────────────────────────────────┐
│ uGroup Architecture │
├─────────────────────────────────────────────────────────────────┤
│ │
│ ┌───────────────────┐ ┌────────────────────────────┐ │
│ │ __consumer_offsets│────▶│ConsumerOffsetTopicProcessor│ │
│ │ (Kafka) │ └────────────┬───────────────┘ │
│ └───────────────────┘ │ │
│ ▼ │
│ ┌─────────────────────────┐ │
│ │CommittedOffsetsCompactor│ │
│ └────────────┬────────────┘ │
│ │ │
│ ▼ │
│ ┌──────────────────┐ ┌───────────────────────────┐ │
│ │WatchListProviders│◀──────│ CompactedOffsetsProcessor │ │
│ └──────────────────┘ └──────────┬────────────────┘ │
│ │ │
│ ┌────────────────────────────────┼────────────────┐ │
│ │ │ │ │
│ ▼ ▼ ▼ │
│ ┌──────────┐ ┌────────────┐ ┌──────────┐ │
│ │ REST API │ │ Prometheus │ │ Caffeine │ │
│ │ /api/v1 │ │ Metrics │ │ Cache │ │
│ └──────────┘ └────────────┘ └──────────┘ │
│ │
└─────────────────────────────────────────────────────────────────┘