Apache Kafka Analitik Eğitimi

Eğitim Hakkında

Kafka Streams ve ksqlDB ile gerçek zamanlı analitik

Bu eğitim, Kafka Streams ve ksqlDB ile gerçek zamanlı akış analitiği kurmayı öğretir. KStream ve KTable soyutlamaları, stateless/stateful dönüşümler, pencere tabanlı toplama (tumbling, hopping, session), stream-table join işlenir. State store ve interactive query, exactly-once processing, ksqlDB ile SQL benzeri akış sorguları, push/pull query ve materialized view uygulamalı ele alınır. Serileştirme, şema yönetimi ve akış topolojisi tasarımı gösterilir.

Süre ve Format

3 Gün. Her gün dört modül; Kafka Streams kodu ve ksqlDB sorguları yazma ağırlıklı labler.

Seviye

Orta Seviye — Kafka Streams ve ksqlDB ile akış analitiği, stateful işleme ve gerçek zamanlı toplamayı kapsar.

Öğrenme Metodu

Canlı topic'ler üzerinde Streams uygulamaları ve ksqlDB sorguları çalıştırarak uygulanır.

Neden Bu Eğitim?

⚡Anlık İçgörü

Akan veriyi beklemeden pencere toplamalarıyla gerçek zamanlı analize dönüştürürsünüz.

🧮SQL ile Akış

ksqlDB ile kod yazmadan SQL benzeri akış sorguları çalıştırırsınız.

💾Stateful

State store ve interactive query ile akış durumunu sorgulanabilir kılarsınız.

Anahtar Konular

kafka streams eğitimiksqldbakış analitiğikstream ktablepencere toplamastream joinstate storematerialized viewgerçek zamanlı analitik

“Analitiği veriye yetiştiren değil, veriyle birlikte akan sistem kazanır.”

Ön Koşullar

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

1

Kafka Temeli

Topic, partition ve consumer group kavramları gerekir.

2

Programlama

Java veya Scala'da temel kod yazabilmek faydalıdır.

3

SQL

ksqlDB için temel SQL beklenir.

4

Lab Ortamı

Kafka ve ksqlDB çalıştıran bir ortam gerekir.

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ı KStream/KTable ile temel akış dönüşümleri yazabilir.

Modül 1

Streams Mimarisi

Streams uygulaması ve topology
KStream vs KTable soyutlaması
Kütüphane olması (broker değil)
Task ve thread paralelliği
Topic-partition eşlemesi
Exactly-once processing (EOS)

Modül 2

Stateless Dönüşüm

filter, map, mapValues
flatMap ve branch
selectKey ve re-keying
merge ve peek
foreach ile yan etki
to/through ile yazma

Modül 3

KTable

KTable ve changelog semantiği
Güncelleme (upsert) davranışı
GlobalKTable kullanımı
Tablo-stream dönüşümü (toStream)
Materialized KTable
Null (tombstone) ile silme

Modül 4

Serileştirme

Serde kavramı
Avro/JSON/Protobuf serde
Schema Registry entegrasyonu
Özel serde yazma
Key/value serde yapılandırma
Şema evrimi etkisi

Günün hedefiKatılımcı pencere toplama ve join ile stateful akış analitiği kurabilir.

Modül 1

Toplama

groupBy ve groupByKey
count, reduce, aggregate
State store ile toplama
Materialized store adlandırma
Toplama sonucu KTable
Toplama state boyutu

Modül 2

Pencereleme

Tumbling window
Hopping window
Session window
Sliding window
Grace period ve geç veri
Pencere sonucu yayma (suppress)

Modül 3

Join

KStream-KStream window join
KStream-KTable join
KTable-KTable join
GlobalKTable join
Co-partitioning gereksinimi
Join sonucu semantiği

Modül 4

State Store

RocksDB state store
Changelog topic ile dayanıklılık
Interactive Queries
Store'u REST ile sorgulama
Standby replica
State restore süreci

Günün hedefiKatılımcı ksqlDB ile akış sorguları yazar ve uygulamayı üretime hazırlar.

Modül 1

ksqlDB Temeli

STREAM ve TABLE oluşturma
Topic'ten stream tanımlama
SELECT ve WHERE ile filtre
Değer formatı (AVRO/JSON)
Key ve timestamp tanımı
ksqlDB mimarisi

Modül 2

ksqlDB Analitik

WINDOW TUMBLING/HOPPING/SESSION
GROUP BY ve toplama
JOIN (stream-table)
Push vs pull query
Materialized view (CREATE TABLE AS)
User-defined function (UDF)

Modül 3

Hata ve Garanti

Exactly-once yapılandırma
Yeniden işleme ve reset
Zehirli kayıt yönetimi
Deserialization hatası
Idempotent çıktı
State kurtarma

Modül 4

Üretim Operasyonu

Uygulama ölçekleme (instance)
Rebalance ve standby
Metrik ve lag izleme
Topology görselleştirme
Sürüm yükseltme
Kapasite planlama

Eğitim Kazanımları

Program sonunda katılımcılar:

✅

Streams DSL

KStream/KTable ile akış dönüşümleri yazarsınız.

✅

Pencere Toplama

Tumbling/hopping/session pencerelerle gerçek zamanlı toplama yaparsınız.

✅

Join

Stream-stream ve stream-table join'leri doğru kurarsınız.

✅

State Store

Interactive query ile akış durumunu sorgulanabilir kılarsınız.

✅

ksqlDB

SQL benzeri sorgularla kod yazmadan akış analitiği üretirsiniz.

✅

Materialized View

ksqlDB ile sürekli güncellenen materialized view kurarsınız.

✅

Exactly-once

EOS yapılandırmasıyla tutarlı akış sonuçları üretirsiniz.

✅

Üretim

Ölçekleme, standby ve izleme ile uygulamayı üretime alırsınız.

Kimler İçin Uygundur?

Gerçek zamanlı analitik kuran geliştiriciler
veri mühendisleri
akış tabanlı mikroservis ekipleri

Sıkça Sorulan Sorular

Bu eğitim kimler için uygundur?

Gerçek zamanlı analitik kuran geliştiriciler, veri mühendisleri ve akış tabanlı mikroservis ekipleri için uygundur.

Kafka Streams mı ksqlDB mi?

İkisi de işlenir; kod kontrolü için Streams, hızlı SQL akış sorguları için ksqlDB ne zaman tercih edilir gösterilir.

KStream ile KTable farkı nedir?

KStream olay akışını, KTable ise anahtar bazlı son durumu (changelog) temsil eder; farklar uygulamalı işlenir.

Önceden Kafka bilmek gerekir mi?

Evet; topic, partition ve consumer group temelleri ön koşuldur.

Sertifika veriliyor mu?

Eğitim sonunda 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

APACHE KAFKA ANALİTİK EĞİTİMİ

Eğitim Hakkında

Neden Bu Eğitim?

Anahtar Konular

Ön Koşullar

Eğitim İçeriği

Streams Mimarisi

Stateless Dönüşüm

KTable

Serileştirme

Toplama

Pencereleme

Join

State Store

ksqlDB Temeli

ksqlDB Analitik

Hata ve Garanti

Üretim Operasyonu

Eğitim Kazanımları

Kimler İçin Uygundur?

Sıkça Sorulan Sorular

Sertifikalandırma

Eğitim Bilgileri

Bu Eğitimle Birlikte Tercih Edilenler

Kafka Eğitimi

Kafka Introduction Eğitimi

KSQL ve Kafka Connect ile Entegrasyon ve Pipeline Tasarım Eğitimi

Loading & Querying Data with Hive Eğitimi

Managing Big Data Operations Eğitimi