Streaming
Beginner-friendly mental models for streaming systems, event time, windows, watermarks, and later Flink internals.
Streaming
Streaming là phần mình muốn học lại từ nền tảng trước: event đến liên tục, có thể tới muộn hoặc lệch thứ tự, hệ thống phải vừa ra kết quả đủ nhanh vừa không làm sai business meaning quá nhiều.
Mục tiêu của section này không phải nhảy ngay vào Flink API hay internals, mà là xây vocabulary thật chắc trước:
event timevsprocessing time- window
- watermark
- late event
- state
- checkpoint
Sau khi mấy khái niệm này rõ hơn, mình mới đi tiếp xuống Flink internals như JobManager/TaskManager, state backend, checkpoint barrier, exactly-once sink, v.v.
TCP Flow Control and Kafka Poll
Why Kafka is pull-based but TCP receive windows can still matter: socket buffers, poll loops, network I/O, and where the mental model gets tricky.
Watermark and Late Events
A beginner mental model for event time, watermarks, late events, and the batch/streaming completeness cutoff problem.