proto.lib

Kẹt Ở Last Stable Offset Với read_committed

Khi producer dùng transaction và consumer đọc isolation.level=read_committed, consumer không thể đọc vượt qua Last Stable Offset (LSO); một transaction chạy dài hoặc bị bỏ rơi sẽ chặn toàn bộ message phía sau nó, khiến lag tăng dù broker hoàn toàn khoẻ mạnh.

MessagingNâng cao2026-08-20
Kẹt Ở Last Stable Offset Với read_committed

Tags

#read-committed#last-stable-offset#kafka-transactions#consumer-lag#transaction-timeout#isolation-level

Tài liệu tham khảo

Mở rộng

Animation gốc là một file HTML tự chứa, có thể nhúng lại ở bất kỳ trang nào khác. Mở file gốc

Liên quan

MessagingTrung bình

Drain Backlog Sau Sự Cố (10 Triệu Message Tồn Đọng)

Khi consumer ngừng chạy nhiều giờ, lag tích tụ hàng chục triệu message; thêm consumer chỉ tăng throughput tới khi số consumer bằng số partition, sau đó consumer thừa đứng chờ vì mỗi partition chỉ gán được một consumer trong cùng group.

#consumer-lag#backlog#partitions#batch-size
MessagingTrung bình

Autoscaling Consumer Theo Queue Depth

Hệ thống tự động tăng/giảm số lượng consumer dựa trên độ sâu hàng đợi hoặc consumer lag để giữ độ trễ xử lý ổn định.

#autoscaling#queue-depth#consumer-lag#scaling
MessagingTrung bình

Kafka Consumer Lag Monitoring & Alerting

Lag là khoảng cách giữa log-end-offset và offset đã commit của consumer group; giám sát lag giúp phát hiện sớm tình trạng consumer xử lý không kịp.

#kafka#consumer-lag#monitoring#alerting