Senior Streaming Flink AI Engineer

• Długofalowa współpraca z międzynarodową firmą z sektora logistyki i transportu, świadczącą usługi na skalę globalną.
• Praca w ramach enterprise'owej platformy Kafka/Confluent (KNITE MEP), działającej w modelu współdzielonej odpowiedzialności z Centralną Platformą i AsyncAPI oraz dostępami Producentów i Konsumentów.
• Projektowanie i wdrażanie mechanizmów filtrowania treści (content-based filtering), projekcji payloadów (payload projection) oraz łączenia topiców (topic joins) jako uzupełnienie istniejącego filtrowania nagłówkowego.
• Tworzenie frameworka reguł filtrowania Flink SQL wraz z narzędziami do walidacji.
• Implementacja niestandardowego pluginu Kafka Connect SMT do transformacji XML-to-Avro (Java).
• Budowa schematu YAML i workflow opartego na Pull Requestach dla samoobsługi konsumentów.
• Integracja z Confluent Schema Registry.
• Przygotowanie manifestów deploymentowych dla Flink Kubernetes Operator.
• Realizacja projektu z aktywnym wykorzystaniem AI na wszystkich fazach cyklu życia (Agentic Engineering).

Wymagania kluczowe:

• Minimum 8 lat doświadczenia zawodowego w IT, ze specjalizacją w obszarze stream processingu i architektur eventowych.
• Zaawansowana znajomość Apache Flink, w tym Flink SQL (wyrażenia filtrujące, projekcje, window joins) oraz Flink Kubernetes Operator (deployment, zarządzanie jobami).
• Biegła znajomość konceptów stateful stream processingu.
• Praktyczna znajomość Apache Kafka / Confluent Platform: model Kafka producer/consumer, Kafka Connect (source/sink connectors, pluginy SMT), Confluent Schema Registry (Avro), zarządzanie topicami i consumer groupami.
• Doświadczenie w projektowaniu i ewolucji schematów Avro oraz korzystaniu z Schema Registry API.
• Umiejętność deployowania i operowania workloadami przez Kubernetes Operator, podstawowego troubleshootingu (logi, stan podów, konfiguracja zasobów).

Mile widziane:

• Znajomość Table API
• Znajomość AsyncAPI v3 (czytanie i tworzenie specyfikacji, struktury komponentów wiadomości – traits, examples).
• Doświadczenie w tworzeniu niestandardowych pluginów Kafka Connect SMT (Java) oraz logiki transformacji XML-to-Avro.
• Znajomość GitOps / CI/CD – workflow'y deploymentu oparte na Pull Requestach, zarządzanie konfiguracją w YAML.