Flink işlerini üretimde güvenle çalıştır ve ölçekle
Apache Flink uygulamalarının üretimde yönetimine odaklanan ileri seviye eğitim: JobManager/TaskManager runtime, olay zamanı ve watermark, keyed/operator state ve RocksDB backend, checkpoint/savepoint ile exactly-once, application/session dağıtım modları, Kube…
Flink runtime, durum yönetimi, checkpoint/savepoint, dağıtım ve izleme
Bu ileri seviye eğitim, Apache Flink uygulamalarının üretim ortamında yönetimine odaklanır. Katılımcılar Flink runtime mimarisini (JobManager, TaskManager, slot, parallelism), olay zamanı işleme ve watermark'ı; keyed state, operator state ve state backend (RocksDB) ile durum yönetimini uygular. Checkpoint, savepoint, exactly-once garantisi ve iki aşamalı commit; application/session/per-job dağıtım modları, Kubernetes ve YARN üzerinde dağıtım işlenir. Ölçekleme (rescaling), backpressure analizi, metrik ve log izleme, durum şeması evrimi ve sürüm yükseltme ele alınır. Eğitim, hata senaryoları ve kurtarma ile üretim hazırlığına yönelik kararlarla tamamlanır.
4 Gün. Her gün dört modül; Flink runtime ve durum yönetiminden dağıtım, ölçekleme ve üretim operasyonuna ilerlenir.
İleri Seviye — Apache Flink uygulamalarının üretim ortamında dağıtımı, durum yönetimi, checkpoint/savepoint ve ölçeklendirilmesi.
Katılımcılar Flink işlerini küme üzerinde dağıtır, checkpoint/savepoint ile durumu yönetir ve backpressure/metrik senaryolarını uygulamalı çözer.
Keyed/operator state ve RocksDB backend ile büyük durumu güvenle yönetirsiniz.
Checkpoint ve savepoint ile exactly-once garantili kurtarma kurarsınız.
Rescaling, backpressure ve izleme ile işleri üretimde sağlıklı tutarsınız.
Eğitimden verim almak için faydalı olacak bilgi ve ortam gereksinimleri
Olay zamanı ve pencereleme kavramlarına aşinalık güçlü biçimde faydalıdır.
Flink DataStream API'si için temel Java/Scala bilgisi beklenir.
Küme, paralellik ve mesajlaşma kavramlarına aşinalık faydalıdır.
Flink kurulu bir küme veya Kubernetes/YARN ortamına erişim.
Programın gün gün akışı aşağıdadır. Bir güne tıklayarak o günün modüllerini ve içeriklerini görebilirsiniz.
Program sonunda katılımcılar:
JobManager/TaskManager ve slot modelini açıklarsınız.
Watermark ve pencerelerle olay zamanlı işleme kurarsınız.
Keyed/operator state ve RocksDB backend ile durumu yönetirsiniz.
Checkpoint ve savepoint ile exactly-once kurtarma sağlarsınız.
Application/session modlarını Kubernetes/YARN üzerinde kurarsınız.
Kafka ve JDBC connector'ları ile transactional sink bağlarsınız.
Backpressure ve metriklerle üretim işlerini sağlıklı tutarsınız.
Savepoint ile rescaling ve güvenli sürüm yükseltme yaparsınız.
Bu eğitim Digital Vizyon Akademi Başarı Sertifikası ile tamamlanır.
Eğitim başında “Ön Test”, bitiminde “Son Test” uygulanarak gelişim ölçümlenir. Değerlendirme formunu dolduran katılımcılar sertifikalarını alır. Sertifikanızın geçerliliğini Sertifika Sorgulama sayfasından doğrulayabilirsiniz.
Spark Structured Streaming ve Kafka ile üretim ölçeğinde akış işleme: olay zamanı pencereleme, stateful join, exactly-once, RocksDB state store ve izleme.
Detayları Gör →
Karmaşık Kafka iş akışlarını zamanlayın, ölçekleyin ve orkestre edin: partition/consumer ölçekleme, cooperative rebalance, KEDA, Strimzi ve dayanıklı mimari.
Detayları Gör →
Apache Spark ortamını kurun ve gezinin: bileşenler, local/standalone/YARN/K8s modları, spark-defaults yapılandırması, spark-submit ve Spark UI ile iş izleme.
Detayları Gör →
PySpark ile Python üzerinden Spark'ı öğrenin: DataFrame işleme, join ve pencere fonksiyonları, Spark SQL, pandas UDF, pyspark.pandas ve performans ayarı.
Detayları Gör →
Spark iç mimarisini derinlemesine öğrenin: Catalyst, Tungsten, DAG scheduler, job/stage/task, shuffle, unified memory modeli, skew ve AQE ile performans teşhisi
Detayları Gör →