Описание услуги
Я собираю боевые потоковые пайплайны на Apache Flink, которые превращают поток событий в мгновенную и достоверную аналитику. Если сейчас данные приходят пачками, а решения отстают от реальности на часы, я закрываю этот разрыв. Джобы проектирую вокруг событийного времени и водяных знаков, поэтому опоздавшие и пришедшие не по порядку события обрабатываются корректно, а не тихо портят метрики. Бэкенды состояния, чекпоинты и сейвпоинты тюню ради высокой пропускной способности и быстрого восстановления после сбоя.
Главный приоритет — корректность под нагрузкой. Реализую сквозную семантику exactly-once: транзакционные приёмники там, где это поддерживается, и идемпотентную запись во всех прочих случаях, чтобы переключение на резерв не удваивало платёж и не теряло заказ. Строю потоковые джойны нескольких источников, обогащаю события справочниками и через Flink CEP ловлю цепочки фрода, отвал в воронке и нарушения SLA в момент их возникновения. Вы получаете чистый код, протестированное развёртывание и документацию для вашей команды; работаю с Kafka, Kinesis, Pulsar, JDBC и объектным хранилищем.
— Событийное время и оконная агрегация
— Exactly-once, чекпоинты и сейвпоинты
— Джойны, обогащение и паттерны Flink CEP
— Реалтайм-аналитика, алертинг и мониторинг
Главный приоритет — корректность под нагрузкой. Реализую сквозную семантику exactly-once: транзакционные приёмники там, где это поддерживается, и идемпотентную запись во всех прочих случаях, чтобы переключение на резерв не удваивало платёж и не теряло заказ. Строю потоковые джойны нескольких источников, обогащаю события справочниками и через Flink CEP ловлю цепочки фрода, отвал в воронке и нарушения SLA в момент их возникновения. Вы получаете чистый код, протестированное развёртывание и документацию для вашей команды; работаю с Kafka, Kinesis, Pulsar, JDBC и объектным хранилищем.
— Событийное время и оконная агрегация
— Exactly-once, чекпоинты и сейвпоинты
— Джойны, обогащение и паттерны Flink CEP
— Реалтайм-аналитика, алертинг и мониторинг
