DESIGNING AND MANAGING KAFKA DATA PIPELINES EĞİTİMİ

Kafka ile gerçek zamanlı veri hatlarını uçtan uca kurun

Topic ve partition tasarımından Kafka Connect, Streams ve şema yönetimine kadar üretim seviyesinde veri hattı mühendisliği.

Apache Kafka üzerinde topic/partition tasarımı, Connect ile entegrasyon, Schema Registry ile şema evrimi, Kafka Streams ve exactly-once semantics odaklı uçtan uca veri hattı mühendisliği eğitimi.

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

Eğitim Hakkında

Tasarım kararları, operasyon ve gözlemlenebilirlik eksenli ileri Kafka veri hattı eğitimi

Bu eğitim, Apache Kafka tabanlı veri hatlarının mimari tasarımını, kurulumunu ve üretim ortamında işletimini ele alır. Topic ve partition boyutlandırma, replication factor ve ISR, producer acks ve idempotency, consumer group ve offset yönetimi, Kafka Connect ile kaynak/hedef entegrasyonu, Single Message Transforms, Schema Registry ile Avro şema evrimi, Kafka Streams ile akış dönüşümleri ve exactly-once semantics gibi somut konuları kapsar. Katılımcı; gecikme, throughput ve veri bütünlüğü hedeflerine göre doğru mimari kararları alır.

Süre ve Format

4 Gün. Her gün dört modül; her modül kavramsal anlatım ve çalışan bir Kafka cluster üzerinde uygulamalı lab içerir.

Seviye

İleri Seviye — Apache Kafka üzerinde uçtan uca veri hatları tasarlama, Kafka Connect ve Streams ile akış işleme ve üretim ortamı işletimi.

Öğrenme Metodu

Docker ile ayağa kaldırılan çok broker'lı Kafka cluster üzerinde CLI, Connect ve Streams uygulamalarıyla laboratuvar çalışması.

Neden Bu Eğitim?

⚡Gerçek Zamanlı

Toplu işleme yerine milisaniye gecikmeli akış hatları tasarlayarak veriyi oluştuğu anda işlersiniz.

🧩Entegrasyon Gücü

Kafka Connect ile veritabanı, nesne depolama ve dış sistemleri kod yazmadan bağlarsınız.

🛡️Veri Bütünlüğü

Idempotent producer ve exactly-once semantics ile yineleme ve veri kaybını önlersiniz.

Anahtar Konular

apache kafkakafka veri hattıkafka connectschema registrykafka streamsexactly-oncedebezium cdckafka eğitimipartition tasarımıakış işleme
“İyi tasarlanmış bir veri hattı, veriyi oluştuğu anda değere dönüştürür.”

Ön Koşullar

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

1
Linux Komut Satırı

Temel kabuk komutları ve servis yönetimi konusunda rahat olmak gerekir.

2
JVM Temelleri

Java veya Scala ile temel kod okuyabilmek Streams örnekleri için faydalıdır.

3
Dağıtık Sistemler

Replication, partition ve consensus kavramlarına aşinalık avantaj sağlar.

4
Docker Ortamı

Çalışma için Docker ve 8 GB RAM'li bir geliştirme makinesi önerilir.

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ı Kafka'nın dağıtık log mimarisini kavrar ve iş yüküne uygun topic/partition tasarımı yapar.
Modül 1
Log ve Broker Mimarisi
  • Append-only commit log ve segment dosyaları
  • Broker, controller ve KRaft/ZooKeeper rolü
  • Partition liderliği ve takipçi replikalar
  • ISR (in-sync replica) kümesi mantığı
  • Leader election ve unclean.leader.election riski
  • Retention: time, size ve compaction politikaları
Modül 2
Partition ve Paralellik
  • Partition sayısının throughput'a etkisi
  • Key tabanlı partitioning ve sıra garantisi
  • Consumer paralelliği ile partition ilişkisi
  • Hot partition ve veri dengesizliği
  • Partition yeniden dengeleme (reassignment)
  • Boyutlandırma için hedef mesaj hızı hesabı
Modül 3
Replication ve Dayanıklılık
  • replication.factor ve min.insync.replicas
  • acks=all ile dayanıklılık garantisi
  • Rack awareness ile hata bölgesi dağıtımı
  • Broker arızasında failover akışı
  • Under-replicated partition tespiti
  • Veri kaybı senaryoları ve önlemleri
Modül 4
Topic Yönetimi
  • kafka-topics.sh ile oluşturma ve inceleme
  • Topic düzeyi config override'ları
  • Compacted topic ile son-değer saklama
  • Topic adlandırma ve namespace stratejisi
  • __consumer_offsets iç topic'i
  • Quota ve throttling tanımları
Günün hedefiKatılımcı producer/consumer ayarlarını teslimat garantileri ışığında yapılandırır.
Modül 1
Producer İç Yapısı
  • Batching: batch.size ve linger.ms
  • Sıkıştırma: lz4, snappy, zstd seçimi
  • acks ve retries ile dayanıklılık
  • enable.idempotence ile çift kayıt önleme
  • Partitioner ve custom partitioning
  • Delivery timeout ve buffer memory ayarı
Modül 2
Consumer ve Gruplar
  • Consumer group ve rebalance protokolü
  • Offset commit: otomatik ve manuel
  • auto.offset.reset: earliest/latest
  • max.poll.records ve işleme süresi
  • Static membership ile rebalance azaltma
  • Lag izleme ve geriden gelme tespiti
Modül 3
Transactions ve EOS
  • Transactional producer API'si
  • read_committed izolasyon seviyesi
  • Exactly-once semantics uçtan uca
  • transactional.id ve fencing
  • Consume-transform-produce deseni
  • Zombie instance koruması
Modül 4
Serileştirme
  • Avro, JSON ve Protobuf karşılaştırması
  • Key ve value serializer seçimi
  • Şema ile tip güvenliği
  • Null handling ve tombstone mesajları
  • Header kullanımı ve metadata
  • Serileştirme hatalarının yönetimi
Günün hedefiKatılımcı Kafka Connect ile dış sistem entegrasyonu kurar ve şema evrimini yönetir.
Modül 1
Connect Mimarisi
  • Standalone ve distributed mod
  • Worker, connector ve task kavramı
  • Converter ve internal topic'ler
  • REST API ile konnektör yönetimi
  • Offset ve status topic'leri
  • Ölçekleme ve task yeniden dağıtımı
Modül 2
Source ve Sink Konnektörler
  • JDBC source ile veritabanı yakalama
  • Debezium ile CDC (change data capture)
  • S3/HDFS sink ile veri gölüne yazma
  • Elasticsearch sink entegrasyonu
  • Dead letter queue yapılandırması
  • errors.tolerance ve retry politikası
Modül 3
Single Message Transforms
  • Field maskeleme ve filtreleme
  • Topic yönlendirme (RegexRouter)
  • Zaman damgası dönüşümleri
  • Key'den value'ya alan taşıma
  • Zincirleme SMT uygulaması
  • Predicate ile koşullu dönüşüm
Modül 4
Schema Registry
  • Avro şema kaydı ve subject'ler
  • BACKWARD/FORWARD/FULL uyumluluk
  • Şema evrimi ve alan ekleme kuralları
  • Schema ID ile mesaj çözümleme
  • Compatibility level yönetimi
  • Confluent REST ile şema inceleme
Günün hedefiKatılımcı Kafka Streams ile dönüşüm hatları yazar ve cluster'ı üretim ortamında izler.
Modül 1
Kafka Streams
  • KStream ve KTable soyutlamaları
  • Stateless map/filter/flatMap işlemleri
  • Stateful aggregation ve windowing
  • State store ve RocksDB kullanımı
  • Join: stream-stream ve stream-table
  • Exactly-once ile stateful işleme
Modül 2
İzleme ve Gözlemlenebilirlik
  • JMX metrikleri ve kritik göstergeler
  • Consumer lag izleme (Burrow/exporter)
  • Prometheus ve Grafana panoları
  • Under-replicated ve offline partition alarmı
  • Request latency ve throughput takibi
  • Log ve audit inceleme
Modül 3
Güvenlik
  • TLS ile şifreli iletişim
  • SASL/SCRAM ve SASL/GSSAPI kimlik doğrulama
  • ACL ile topic yetkilendirme
  • Quota ile istemci sınırlama
  • Hassas verinin şifrelenmesi
  • Ağ segmentasyonu ve listener ayrımı
Modül 4
Kapasite ve Operasyon
  • Broker boyutlandırma ve disk planı
  • Partition reassignment ve veri taşıma
  • Rolling restart ve versiyon yükseltme
  • Felaket kurtarma ve MirrorMaker 2
  • Yedekleme ve retention stratejisi
  • Kapasite testi ve performans ayarı

Eğitim Kazanımları

Program sonunda katılımcılar:

✅
Mimari Kararlar

İş yüküne göre topic, partition ve replication tasarımını gerekçeli biçimde yapabilirsiniz.

✅
Teslimat Garantileri

Idempotency ve exactly-once semantics ile veri kaybı ve yinelemeyi önleyebilirsiniz.

✅
Connect Entegrasyonu

Kafka Connect ve Debezium ile CDC tabanlı entegrasyon hatları kurabilirsiniz.

✅
Şema Yönetimi

Schema Registry ile uyumlu şema evrimi yönetebilirsiniz.

✅
Akış İşleme

Kafka Streams ile stateful dönüşüm ve pencere işlemleri yazabilirsiniz.

✅
Gözlemlenebilirlik

Consumer lag ve broker metriklerini izleyip alarm kurabilirsiniz.

✅
Güvenlik

TLS, SASL ve ACL ile cluster erişimini güvenli hale getirebilirsiniz.

✅
Üretim İşletimi

Rolling upgrade, reassignment ve felaket kurtarma süreçlerini yürütebilirsiniz.

Kimler İçin Uygundur?

  • Akış veri hatları kuracak veri mühendisleri
  • platform
  • DevOps ekipleri ile olay tabanlı mimari tasarlayan yazılım mimarları için uygundur

Sıkça Sorulan Sorular

Bu eğitim kimler için uygundur?
Akış veri hatları kuracak veri mühendisleri, platform/DevOps ekipleri ve olay tabanlı mimari tasarlayan yazılım mimarları için uygundur.
Exactly-once semantics gerçekten kayıpsız mı?
Transactional producer, idempotency ve read_committed birlikte kullanıldığında consume-transform-produce hattında uçtan uca tam-bir-kez garantisi sağlanır.
Kafka Connect için kod yazmak gerekir mi?
Hazır source/sink konnektörler ve SMT ile çoğu entegrasyon kod yazmadan yapılır; özel ihtiyaçlar için konnektör geliştirme de ele alınır.
Hangi ortamda çalışacağız?
Docker ile ayağa kaldırılan çok broker'lı bir cluster üzerinde CLI, Connect ve Streams uygulamalarıyla çalışılır.
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 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. Designing and Managing Kafka Data Pipelines 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

Büyük Veri TeknolojileriIntroduction to Apache Flink Eğitimi
Veri ve Analitik Eğitimleri

Introduction to Apache Flink Eğitimi

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

Apache Flink'e giriş: DataStream API, event-time, watermark, keyed state, pencereleme, checkpoint ve Kafka entegrasyonu. Uygulamalı temel seviye eğitim.

Detayları Gör →
Büyük Veri TeknolojileriIntroduction to Apache Spark Eğitimi
Veri ve Analitik Eğitimleri

Introduction to Apache Spark Eğitimi

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

Apache Spark'a giriş: driver/executor mimarisi, RDD, transformation/action, DataFrame, Spark SQL, Parquet ve önbellekleme. Uygulamalı temel seviye eğitim.

Detayları Gör →
Büyük Veri TeknolojileriIntroduction to Hadoop Eğitimi
Veri ve Analitik Eğitimleri

Introduction to Hadoop Eğitimi

2 günBaşlangıçOnline / Yüz Yüze / Hibrit

Hadoop'a kapsamlı giriş: büyük veri 3V, HDFS, YARN, MapReduce ve Hive/Pig/HBase/Spark ekosistemi ile dağıtım/bulut seçenekleri. Başlangıç seviyesi eğitim.

Detayları Gör →
Büyük Veri TeknolojileriIntroduction to Spark Structured Streaming and MLlib Eğitimi
Veri ve Analitik Eğitimleri

Introduction to Spark Structured Streaming and MLlib Eğitimi

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

Spark Structured Streaming ile akış işleme ve MLlib pipeline ile ölçeklenebilir ML'i birleştirin: watermark, checkpoint, model eğitimi ve akışta skorlama.

Detayları Gör →
Büyük Veri TeknolojileriIntroduction to the Shell for Hadoop HDFS Eğitimi
Veri ve Analitik Eğitimleri

Introduction to the Shell for Hadoop HDFS Eğitimi

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

HDFS mimarisini öğrenin ve hdfs dfs komutlarıyla veri yükleme, izin, replikasyon, kota, fsck ve bakım işlemlerini uygulamalı yönetin. Temel seviye DVA eğitimi.

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