.NET İLE APACHE KAFKA VE OLAY TABANLI MİMARİ EĞİTİMİ

- Commit Log Mimarisi: Veriler diskte kalici ve sirali olarak tutulur.
- Partition & Ordering: Mesaj siralamasi yalnizca partition bazinda garanti edilir.
- Consumer Groups: Her partition bir gruptaki sadece bir consumer'a atanabilir.
- KRaft (Metadata Quorum): Zookeeper bagimliligi olmadan controller replication.

var config = new ProducerConfig
{
    BootstrapServers = "kafka:9092",
    EnableIdempotence = true,        // Sequence number tabanlı tekrar gönderim koruması
    Acks = Acks.All,                 // min.insync.replicas ile birlikte veri dayanıklılığı
    MaxInFlight = 5,
    CompressionType = CompressionType.Snappy
};

using var producer = new ProducerBuilder<string, string>(config).Build();

try
{
    var result = await producer.ProduceAsync("order-events", new Message<string, string>
    {
        Key = "order-42",
        Value = JsonSerializer.Serialize(new { OrderId = 42, Status = "Created" }),
        Headers = new Headers { { "source-service", Encoding.UTF8.GetBytes("order-svc") } }
    });

    _logger.LogInformation("Delivered to {TopicPartitionOffset}", result.TopicPartitionOffset);
}
catch (ProduceException<string, string> ex) when (ex.Error.IsFatal)
{
    _logger.LogCritical("Fatal producer error: {Reason}", ex.Error.Reason);
    throw;
}

public class OrderEventConsumer : BackgroundService
{
    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        var config = new ConsumerConfig
        {
            BootstrapServers = "kafka:9092",
            GroupId = "order-processor-v1",
            AutoOffsetReset = AutoOffsetReset.Earliest,
            EnableAutoCommit = false          // Manuel commit — at-least-once garantisi
        };

        using var consumer = new ConsumerBuilder<string, string>(config).Build();
        consumer.Subscribe("order-events");

        while (!stoppingToken.IsCancellationRequested)
        {
            var result = consumer.Consume(TimeSpan.FromSeconds(1));
            if (result is null) continue;

            try
            {
                await ProcessOrderAsync(result.Message, stoppingToken);
                consumer.Commit(result);      // Başarılı işlemden sonra commit
            }
            catch (RetryableException ex)
            {
                await _deadLetterProducer.SendAsync("order-events-dlt", result.Message);
                consumer.Commit(result);      // DLT'ye gönderildikten sonra commit
                _logger.LogWarning(ex, "Sent to DLT: {Key}", result.Message.Key);
            }
        }
    }
}

- Schema Compatibility: BACKWARD, FORWARD, FULL, NONE.
- Serialization: Avro/Protobuf serilestirme ile binary payload aktarimi.
- Subject Naming Strategies: TopicNameStrategy, RecordNameStrategy.
- Schema Evolution: Uyumlu alan ekleme/silme senaryoları.

Sen, kıdemli bir Olay Güdümlü Sistem Mimarı ve .NET Uzmanısın.
Sistem Bağlamı: {sistem_aciklamasi}
Beklenen Throughput: {throughput} req/sec
Kritik Veri Tutarlılığı Eşiği: {consistency_level} (EOS/At-least-once)

Aşağıdaki mimari şablonu tasarla:
1. Kafka Topic & Partition Tasarımı (Message Key stratejisi)
2. transactional.id ve Outbox tablosu şeması (.NET Entity Framework Core)
3. KStream-KTable Join ve Windowed Fraud Detection sorguları
4. Olası Rebalance sürelerini minimize edecek Consumer Group konfigürasyonu
5. Saga Choreography adımları ve Compensating Action akış şeması

.NET ile Apache Kafka ve Olay Tabanlı Mimari Eğitimi,.NET, C#, Apache Kafka, Confluent.Kafka, Producer, Consumer, Consumer Group, Topic, Partition, Offset, Acks, Idempotent Producer, Transactional API, Exactly Once, At Least Once, Schema Registry, Avro, Protobuf, Kafka Connect, Debezium, JDBC Connector, Kafka Streams, KSQLdb, Event Sourcing, CQRS, Saga, Log Compaction, SASL, ACL, TLS, SSL, JMX, Prometheus, Grafana, Strimzi, Kubernetes, Docker, Terraform, CI/CD, GitHub Actions, Azure DevOps, Real-time Analytics, Event-driven Architecture, Microservices, Eğitimler, Kurumsal Eğitimler, Kurumsal Kubernetes Eğitimi, Grup Kubernetes Eğitimi, Şirketler İçin Kubernetes Eğitimi, Şirket İçi Kubernetes Eğitimi, KOBİ için Kubernetes Eğitimi, Sektöre Özel Kubernetes Eğitimi, Online Kubernetes Bootcamp, Kubernetes Sertifikasyon Hazırlık Eğitimi, Kubernetes Destek Hizmetleri, Kurumsal Kubernetes Çözümleri, Uzaktan Kubernetes Destek Hizmetleri, Kubernetes Uygulamalı Workshop ve Sertifika Programları, Uygulamalı Kubernetes Eğitim Programları, Başlangıç Seviyesinden Uzmanlığa Kubernetes Eğitim Paketleri, Kubernetes Eğitimi, Kubernetes Desteği, Kubernetes, Docker, RedHat, DevSecOps, Yapay Zeka, Siber Güvenlik, Proje Yönetimi, Hands-On Eğitimler, NLP Eğitimleri, Kubernetes Mimarisi, Multi Cluster Yönetimi, Microservisler, IT Danışmanlık, Altyapı Optimizasyonu, DevOps Çözümleri, Kubernetes Hands-On Eğitimleri, Kubernetes Cluster Yönetimi, Kubernetes Sertifikasyonu, Docker, Docker Kurulum, Docker Eğitim, Docker Destek, Docker Partnerlik, Container Teknolojileri, Docker Kubernetes, Container Orchestration, Docker Scaling, Kubernetes Entegrasyonu, Docker Pipeline, Mikroservis Mimarileri, CI/CD Çözümleri, DevOps ve DevSecOps Süreçleri, Kubernetes Modern Altyapılar, Kubernetes OpenShift, Cloud Native Çözümler, Multi Cluster Docker, Kubernetes Monitoring, Kubernetes Migration, DevOps Altyapısı, Kubernetes Güvenlik Çözümleri, Kubernetes ile Otomasyon, Yapay Zeka Çözümleri, Makine Öğrenimi, Derin Öğrenme, AI Model Eğitimi, AI Optimizasyonu, AI Proje Yönetimi, Yapay Zeka Danışmanlığı, AI Kurulum Destek, Siber Güvenlik, Veri Güvenliği, KVKK Uyumluluğu, GDPR Uyumluluğu, Red Hat Siber Güvenlik Çözümleri, AI Proaktif Hizmetler, Siber Güvenlik Eğitimi, Agile Metodolojisi, Proje Yönetimi Danışmanlığı, Çevik Proje Yönetimi, Mikroservisler, Yazılım Geliştirme, API Yönetimi, Kubernetes API Gateway, Kod İnceleme, Yazılım Testi, Versiyon Kontrolü, CICD, Mobil Uygulama Geliştirme, Spring Boot, Cloud Native Uygulamalar, Sanallaştırma, Virtualization, VMware, HyperV, Bulut Bilişim, Private Cloud, Public Cloud, Multi Cluster Yönetimi, IT Altyapı Modernizasyonu, Performans İzleme, Yük Dengeleme Çözümleri, Kubernetes ve Bulut Entegrasyonu, DevOps, DevSecOps, CI/CD, Ansible ile Otomasyon, Red Hat Linux, Red Hat OpenShift, Red Hat Eğitimleri, Red Hat Sertifikasyon Programları, Red Hat Enterprise Linux, Red Hat Altyapı Çözümleri. #KurumsalEğitimler #HandsOnEğitimler #KubernetesEğitimi #DockerEğitimi #RedHatEğitimi #DevOpsEğitimi #DevSecOpsEğitimi #YapayZekaEğitimi #SiberGüvenlikEğitimi #ProjeYönetimiEğitimi #NLP #KubernetesCluster #KubernetesYönetimi #KubernetesMimarisi #KubernetesÇözümleri #KubernetesHandsOn #KubernetesDevSecOps #KubernetesDestek #KubernetesKurulumu #KubernetesOptimize #KubernetesMultiCluster #KubernetesOpenShift #KubernetesRedHat #KubernetesModernAltyapı #DockerKurulum #DockerScaling #DockerMigration #DockerContainer #DockerMonitoring #ContainerOrchestration #MultiClusterDocker #DockerDevOps #DockerSecurity#AIPlatformları #MakineÖğrenimiEğitimi #AIModelGeliştirme #DerinÖğrenme #AIUygulamaları #AIProjeDanışmanlığı #AIEğitimleri #AIOptimizasyonu #AIEntegrasyonu #AIHandsOn #ContinuousIntegration #ContinuousDeployment #CI_CD #Mikroservisler #VersiyonKontrolü #ServiceMesh #CloudNative #ProaktifHizmetler #DevSecOpsBlueprint #DevSecOpsAutomation #VeriGüvenliği #GDPRUyumluluk #KVKKUyumluÇözümler #EthicalHacking #SiberGüvenlikDanışmanlığı #CloudSecurity #ITDanışmanlık #AltyapıOptimizasyonu #CloudComputing #KurumsalPartnerlik #UzaktanDestek #SanallaştırmaEğitimleri #KurumsalITÇözümleri #HibritAltyapılar #YedeklemeÇözümleri #DisasterRecovery