VERİ AKIŞI VE GERÇEK ZAMANLI VERİ İŞLEME EĞİTİMİ

Veriyi akarken gerçek zamanlı işleyin

Kafka ile veri akışı, Flink/Spark Structured Streaming, olay zamanı pencereleme, watermark ve exactly-once garantilerini öğrenin.

Gerçek zamanlı akış işleme: Kafka topic/partition ve teslim semantiği, Flink/Spark Structured Streaming, keyed state, olay zamanı ve watermark, pencereleme ve akış join, exactly-once ve checkpoint ile güvenilir üretim uygulamalı işlenir.

4 gün İleri Seviye Online / Yüz Yüze / Hibrit Sertifikalı

Eğitim Hakkında

Kafka, Flink ve Spark ile gerçek zamanlı akış işleme

Bu eğitim, verinin toplu (batch) değil akarken işlendiği gerçek zamanlı akış işleme (stream processing) mimarilerini uygulamalı öğretir. Olay akışı kavramı, mesaj kuyruğu ve log tabanlı yayın/abonelik ele alınır. Apache Kafka ile topic, partition, producer/consumer, consumer group, offset ve teslim semantiği işlenir. Akış işleme motorlarında (Apache Flink ve Spark Structured Streaming) sürekli sorgu, durum (state) yönetimi, olay zamanı (event time) ve işlem zamanı farkı, pencereleme (tumbling/sliding/session window), watermark ve geç gelen veri uygulanır. Exactly-once vs at-least-once garantileri, checkpoint, backpressure ve ölçeklenme gösterilir. Akış-tablo ikiliği, stream-stream/stream-table join ve gerçek zamanlı toplulaştırma ile dolandırıcılık/izleme gibi senaryolar kurgulanır.

Süre ve Format

4 Gün. Her gün dört modül; her konu Kafka ve bir akış motoru üzerinde lab ile uygulanır.

Seviye

İleri Seviye — Akış işleme: Kafka, Flink/Spark Structured Streaming, pencereleme ve exactly-once.

Öğrenme Metodu

Kafka ve Flink/Spark lab ortamında producer/consumer ve pencereli akış işleme uygulamaları.

Neden Bu Eğitim?

⏱️Gerçek Zaman

Veriyi saniyeler içinde işleyip anında karar üretirsiniz.

🪟Pencereleme

Olay zamanı ve watermark ile doğru zamanlı toplulaştırma kurarsınız.

🎯Doğru Teslim

Exactly-once ve checkpoint ile veri kaybı/çoğaltmayı önlersiniz.

Anahtar Konular

veri akışıstream processingapache kafkaapache flinkspark streamingwatermarkexactly-oncepencerelemecheckpointgerçek zamanlı veri
“Gerçek zamanda değer, veriyi beklemeden akarken anlamlandırmaktan doğar.”

Ön Koşullar

Eğitimden verim almak için faydalı olacak bilgi ve ortam gereksinimleri

1
Programlama

Java/Scala veya Python ile temel kodlama avantaj sağlar.

2
Dağıtık Sistem

Kuyruk, küme ve ölçeklenme kavramına aşinalık faydalıdır.

3
SQL

Toplulaştırma ve join mantığını bilmek yardımcı olur.

4
Ortam

Kafka ve Flink/Spark çalıştırılabilen (Docker) lab ortamı.

Eğitim İçeriği

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.

Günün hedefiKatılımcı, akış mimarisini kavrar ve Kafka ile akış kurar.
Modül 1
Akış Kavramı
  • Batch vs stream işleme
  • Sınırsız (unbounded) veri
  • Olay (event) ve zaman damgası
  • Yayın/abonelik modeli
  • Lambda ve Kappa mimarisi
  • Kullanım senaryoları
Modül 2
Kafka Mimarisi
  • Topic ve partition
  • Broker ve replication
  • Leader/follower ve ISR
  • Log retention ve compaction
  • ZooKeeper/KRaft rolü
  • Ölçeklenme ilkesi
Modül 3
Producer ve Consumer
  • Producer ve key ile partitioning
  • acks ve dayanıklılık
  • Consumer group ve rebalance
  • Offset ve commit
  • Consumer lag izleme
  • Seri/deseri (Avro/JSON)
Modül 4
Teslim Semantiği
  • At-most/at-least/exactly-once
  • Idempotent producer
  • Transactional producer
  • Yinelenen mesaj yönetimi
  • Sıra (ordering) garantisi
  • Hata ve yeniden deneme
Günün hedefiKatılımcı, akış motoruyla sürekli sorgu yazar ve durumu yönetir.
Modül 1
Motor Modeli
  • Flink ve Spark Structured Streaming
  • Dataflow ve operator
  • Mikro-batch vs gerçek akış
  • Kaynak (source) ve sink
  • Paralellik ve slot/task
  • Dağıtık yürütme
Modül 2
Akış Dönüşümleri
  • map, filter, flatMap
  • keyBy / groupByKey
  • Toplulaştırma (aggregate)
  • union ve connect
  • Yeniden bölümleme (rebalance)
  • Projeksiyon ve filtre
Modül 3
Durum Yönetimi
  • Stateful operator kavramı
  • Keyed state türleri
  • State backend (RocksDB)
  • State TTL
  • Büyük state yönetimi
  • State ve ölçeklenme
Modül 4
Olay Zamanı
  • Event time vs processing time
  • Zaman damgası atama
  • Watermark üretimi
  • Geç gelen (late) olay
  • Allowed lateness
  • Sıra bozukluğu (out-of-order)
Günün hedefiKatılımcı, pencereleme ve join ile zaman tabanlı analiz kurar.
Modül 1
Pencere Türleri
  • Tumbling (sabit) pencere
  • Sliding (kayan) pencere
  • Session (oturum) penceresi
  • Global pencere
  • Trigger ve evaluation
  • Pencere sonucu yayınlama
Modül 2
Watermark ve Zamanlama
  • Watermark ilerlemesi
  • Pencere kapanış mantığı
  • Geç veriyi yeniden işleme
  • Yan çıktı (side output)
  • Idle kaynak yönetimi
  • Gecikme-doğruluk dengesi
Modül 3
Akış Birleştirme
  • Stream-stream join
  • Zaman aralıklı (interval) join
  • Stream-table join
  • Lookup/enrichment join
  • Join state büyümesi
  • Birleştirme doğrulama
Modül 4
Toplulaştırma
  • Pencere bazlı toplama
  • Kayan ortalama/sayım
  • Top-N ve sıralama
  • Birikimli (incremental) toplama
  • Yaklaşık (approx) sayım
  • Sonucu alt sisteme yazma
Günün hedefiKatılımcı, akış işini güvenilir ve ölçeklenebilir biçimde üretime alır.
Modül 1
Checkpoint ve Kurtarma
  • Checkpoint ve savepoint
  • Durum anlık görüntüsü
  • Hata sonrası kurtarma
  • Barrier ve hizalama
  • State geri yükleme
  • Yeniden başlatma stratejisi
Modül 2
Exactly-Once Uçtan Uca
  • Kaynak-işlem-sink garantisi
  • İki fazlı commit (2PC) sink
  • Idempotent yazma
  • Transactional sink (Kafka)
  • Yinelenmeyi önleme
  • Garanti sınırlarını anlama
Modül 3
Backpressure ve Ölçek
  • Backpressure teşhisi
  • Paralellik ayarı
  • Yeniden ölçekleme (rescale)
  • Kaynak/sink darboğazı
  • Veri eğriltme (skew) yönetimi
  • Kapasite planlama
Modül 4
İzleme ve Dağıtım
  • Metrik ve gecikme (latency) izleme
  • Consumer lag ve throughput
  • Uyarı ve SLA
  • Dağıtım (Kubernetes) modeli
  • Sürüm ve state uyumu
  • Olay sonrası inceleme

Eğitim Kazanımları

Program sonunda katılımcılar:

✅
Akış Mimarisi

Batch ve stream farkını kavrar, akış mimarisi tasarlarsınız.

✅
Kafka

Topic/partition ve consumer group ile akış kurarsınız.

✅
Teslim Semantiği

Exactly-once ve idempotent üretimi uygularsınız.

✅
Durum

Keyed state ve state backend ile durumu yönetirsiniz.

✅
Olay Zamanı

Event time ve watermark ile geç veriyi yönetirsiniz.

✅
Pencereleme

Tumbling/sliding/session pencerelerle toplulaştırırsınız.

✅
Akış Join

Stream-stream ve stream-table join kurarsınız.

✅
Güvenilirlik

Checkpoint ve backpressure yönetimiyle üretime alırsınız.

Kimler İçin Uygundur?

  • Veri mühendisleri
  • platform mühendisleri
  • gerçek zamanlı veri boru hatları kurmak isteyenler için uygundur

Sıkça Sorulan Sorular

Bu eğitim kimler için uygundur?
Veri mühendisleri, platform mühendisleri ve gerçek zamanlı veri boru hatları kurmak isteyenler için uygundur.
Kafka bilmek şart mı?
Hayır; Kafka temelleri topic/partition ve consumer group düzeyinde sıfırdan ele alınır.
Exactly-once gerçekten mümkün mü?
Evet; idempotent/transactional üretim, 2PC sink ve checkpoint ile uçtan uca exactly-once koşulları gösterilir.
Flink mi Spark mı öğretiliyor?
İkisinin akış modeli karşılaştırmalı ele alınır; pencereleme ve watermark kavramları her ikisinde uygulanır.
Eğitim sonunda sertifika veriliyor mu?
Katılım ve değerlendirme sonrası Digital Vizyon Akademi Katılım ve Başarı Sertifikası verilir.

Sertifikalandırma

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.

Örnek Sertifika d Digital Vizyon AKADEMİ KATILIM SERTİFİKASI Bu sertifika [Katılımcı Adı Soyadı] adlı katılımcının aşağıdaki eğitim programını başarıyla tamamladığını belgeler. Veri Akışı ve Gerçek Zamanlı Veri İşleme Eğitimi Sertifika Kodu DV-2026XX00 Tarih 26.10.2026 Yetkili İmza DV AKADEMİ

Eğitim Bilgileri

Süre4 gün
Seviyeİleri Seviye
FormatOnline / Yüz Yüze / Hibrit
Sertifika✓ Var
Hemen Bilgi Al
İlgili Eğitimler

Bu Eğitimle Birlikte Tercih Edilenler

Veri Analizi ve İstatistikKenar Bilişim (Edge Computing) Mimarisi ve Mikro Veri Merkezleri Eğitimi
Veri ve Analitik Eğitimleri

Kenar Bilişim (Edge Computing) Mimarisi ve Mikro Veri Merkezleri Eğitimi

3 günİleriOnline / Yüz Yüze / Hibrit

Kenar bilişim mimarisini tasarlayın: kenar katmanları, mikro veri merkezi topolojisi, MQTT veri toplama, kenar akış işleme ve bulut senkronizasyonu. İleri DVA e

Detayları Gör →
Veri Analizi ve İstatistikKenar Bilişim Mimarisi ve Mikro Veri Merkezleri Eğitimi
Veri ve Analitik Eğitimleri

Kenar Bilişim Mimarisi ve Mikro Veri Merkezleri Eğitimi

3 günOrtaOnline / Yüz Yüze / Hibrit

Kenar bilişim ve mikro veri merkezlerini kurun ve işletin: provisioning, K3s/KubeEdge iş yükleri, izleme, OTA güncelleme ve filo yönetimi. Orta seviye DVA eğiti

Detayları Gör →
Veri Analizi ve İstatistikKey Statistical Concepts Eğitimi
Veri ve Analitik Eğitimleri

Key Statistical Concepts Eğitimi

2 günTemelOnline / Yüz Yüze / Hibrit

Analizin dayandığı anahtar istatistik kavramlarını öğrenin: dağılım, normal dağılım, olasılık, güven aralığı, p-değeri ve yaygın tuzaklar. Temel DVA eğitimi.

Detayları Gör →
Veri Analizi ve İstatistikKibana & Reporting Capabilities Eğitimi
Veri ve Analitik Eğitimleri

Kibana & Reporting Capabilities Eğitimi

3 günOrtaOnline / Yüz Yüze / Hibrit

Kibana'yı öğrenin: Discover, KQL, Lens görselleştirme, dashboard, Maps, zamanlanmış raporlama ve alerting. Elasticsearch verisi için orta seviye DVA eğitimi.

Detayları Gör →
Veri Analizi ve İstatistikKNIME Analitik Platforması - Tam Eğitim Eğitimi
Veri ve Analitik Eğitimleri

KNIME Analitik Platforması - Tam Eğitim Eğitimi

4 günOrtaOnline / Yüz Yüze / Hibrit

KNIME Analytics Platform'u uçtan uca öğrenin: node workflow, veri dönüştürme, görselleştirme, flow variable ve makine öğrenmesi. Orta seviye DVA eğitimi.

Detayları Gör →
+90 (501) 369 40 14 WhatsApp [email protected] LinkedIn