Über den Service
ÜbersetztIch baue Produktions-Streaming-Pipelines auf Apache Flink, die Ereignisströme in sofortige und zuverlässige Analysen umwandeln. Wenn Daten jetzt in Batches ankommen und Erkenntnisse der Realität um Stunden hinterherhinken, schließe ich diese Lücke. Ich entwerfe Jobs rund um Ereigniszeit und Wasserzeichen, sodass verspätete und außer der Reihe eintreffende Ereignisse korrekt behandelt werden, ohne Metriken stillschweigend zu brechen. Zustands-Backends, Checkpoints und Savepoints passe ich für hohe Durchsatzraten und schnelle Wiederherstellung von Ausfällen an.
Die oberste Priorität ist Korrektheit unter Last. Ich implementiere End-to-End genau-einmal Semantik: transaktionale Senken, wo unterstützt, idempotente Schreibvorgänge überall sonst, sodass Failover keine doppelten Gebühren verursacht und keine Bestellungen verloren gehen. Ich baue Streaming-Joins über mehrere Quellen, bereichere Ereignisse mit Referenzdaten und erkenne Betrugsketten, Trichterabfälle und SLA-Verletzungen in dem Moment, in dem sie durch Flink CEP auftreten. Sie erhalten sauberen Code, getestete Bereitstellung und Dokumentation für Ihr Team; ich arbeite mit Kafka, Kinesis, Pulsar, JDBC und Objektspeicher.
— Ereigniszeit und Fensteraggregation
— Genau-einmal, Checkpoints und Savepoints
— Joins, Anreicherung und Flink CEP-Muster
— Echtzeitanalysen, Alarmierung und Überwachung
Die oberste Priorität ist Korrektheit unter Last. Ich implementiere End-to-End genau-einmal Semantik: transaktionale Senken, wo unterstützt, idempotente Schreibvorgänge überall sonst, sodass Failover keine doppelten Gebühren verursacht und keine Bestellungen verloren gehen. Ich baue Streaming-Joins über mehrere Quellen, bereichere Ereignisse mit Referenzdaten und erkenne Betrugsketten, Trichterabfälle und SLA-Verletzungen in dem Moment, in dem sie durch Flink CEP auftreten. Sie erhalten sauberen Code, getestete Bereitstellung und Dokumentation für Ihr Team; ich arbeite mit Kafka, Kinesis, Pulsar, JDBC und Objektspeicher.
— Ereigniszeit und Fensteraggregation
— Genau-einmal, Checkpoints und Savepoints
— Joins, Anreicherung und Flink CEP-Muster
— Echtzeitanalysen, Alarmierung und Überwachung
