Backpressure

Backpressure и load shedding: как система защищает себя

Backpressure и load shedding: как система защищает себя

Rate limiting ограничивает клиента, но что делать, когда система сама не тянет? Backpressure (распространить «притормози» вверх по цепочке через bounded queues) и load shedding (сознательно отбросить часть нагрузки, чтобы не упасть целиком) — механика самозащиты: почему неограниченные очереди убивают, adaptive concurrency, приоритезация и деградация, и чем это отличается от rate limiting и circuit breaker

Flink SQL, коннекторы и эксплуатация: от Table API до прода

Flink SQL, коннекторы и эксплуатация: от Table API до прода

Писать Flink-джобы на низкоуровневом API нужно не всегда: Table API и Flink SQL закрывают большую часть задач декларативно, включая стриминговые джойны и агрегации. Плюс то, без чего не выйти в прод: коннекторы (Kafka, CDC, lakehouse), управление параллелизмом, диагностика backpressure, тюнинг чекпоинтов и апгрейд джобы через savepoint без потери состояния. Завершает погружение практикой эксплуатации