Phần 3: Kiến trúc Event Streaming với Kafka & Flink

Phần 3: Kiến trúc Event Streaming với Kafka & Flink

← Chương trước: Phần 2 — Geospatial Indexing: H3, S2 Geometry & Redis GEO | Mục lục Series | Chương tiếp theo: Thuật Toán Gọi Xe: Cách Uber DISCO & Grab DispatchGym Ghép Tài Xế → Answer-first: Xương sống Event Streaming với Apache Kafka và Apache Flink xử lý hàng triệu sự kiện GPS/giây với độ trễ dưới 100ms. Thiết kế phân vùng theo H3 cell hoặc geohash đảm bảo thứ tự sự kiện, kết hợp Flink stateful stream joins tính toán giá bão và bảo đảm exactly-once billing. ...

6 tháng 5, 2026 · 7 phút · Lê Tuấn Anh
Kiến Trúc Hướng Sự Kiện (Event-Driven Architecture) & Kafka — Worker Pool, Backpressure & Exactly-Once

Kiến Trúc Hướng Sự Kiện (Event-Driven Architecture) & Kafka — Worker Pool, Backpressure & Exactly-Once

← Chương trước: Mở Rộng Cơ Sở Dữ Liệu & Tối Ưu Bể Kết Nối — Sharding, TiDB & PostgreSQL | Mục lục Series | Chương tiếp theo: Khóa Phân Tán (Distributed Locks) — Toán Học Redlock, etcd Raft & Chống Chia Cắt Mạng → Answer-first: Kiến trúc Event-Driven với Apache Kafka tận dụng cơ chế zero-copy sendfile và sparse index để đạt throughput hàng triệu msg/s. Trong Go, mô hình Bounded Worker Pool tạo áp lực ngược (backpressure) tự nhiên và xử lý tuần tự theo partition, đảm bảo ngữ nghĩa exactly-once cho các luồng thanh toán. ...

18 tháng 6, 2026 · 12 phút · Lê Tuấn Anh