Опис послуги
ПерекладЯ збираю бойові потокові конвеєри на 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
— Реалтайм-аналітика, алертинг та моніторинг
