Genel Bakış
Amacı Nedir?
Amacı Nedir?
Merkezi Yönetim
Standart Yapılandırma
Güvenlik
Test Fonksiyonu
Çalışma Prensibi
Çalışma Prensibi
Bağlantı Başlatma
Connection Pool Yönetimi
Kimlik Doğrulama
Veri İletişimi
Bağlantı Yönetimi
Hata Yönetimi
Kullanım Alanları
Kullanım Alanları
Integration Flow Mesajlaşma
Connector Veri Toplama
Scheduled Job Telemetri
Teknik Özellikler ve Yetenekler
Temel Özellikler
Temel Özellikler
Topic Bazlı Mesajlama
Dinamik Kafka PropertiesMap
Yerleşik Ad Eşsizliği Kontrolü
Ortam Bazlı Yapılandırma
Enable/Disable Kontrolü
İleri Düzey Özellikler
İleri Düzey Özellikler
SASL/SCRAM Desteği
Keystore-Truststore Yönetimi
Dinamik Protokol Seçimi
Connection Test Özelliği
Export/Import Özelliği
Connection Monitoring
Connection Parametreleri
Zorunlu Parametreler
Zorunlu Parametreler
Name
Örnek Değer:
Production_KafkaTopic01Notlar: Boşlukla başlamaz, özel karakterler kullanılmamalı
Environment (Ortam)
Örnek Değer:
DevelopmentNotlar: Ortam değiştirmek aynı Connection içinde parametrik yönetim sağlar
Topic Name
Örnek Değer:
audit.events.v1Notlar: Producer ve consumer adımlarında aynı topic kullanılmalıdır
Properties Map
Örnek Değer:
bootstrap.servers=broker1:9092Notlar: En az bir kayıt olmalı; MapValue tipleri doğru seçilmelidir
İsteğe Bağlı Parametreler
İsteğe Bağlı Parametreler
Description
Varsayılan Değer: (Boş)
Önerilen Değer: Prod audit topic publish connection
Enable Secure
Varsayılan Değer: false
Önerilen Değer: true (Production)
Protocol Types
Varsayılan Değer: (Boş)
Önerilen Değer: TLSv1.2, TLSv1.3
KeyStoreId
Varsayılan Değer: (Boş)
Önerilen Değer: ks-prod-clients
TrustStoreId
Varsayılan Değer: (Boş)
Önerilen Değer: ts-shared-root
Deploy To Worker
Varsayılan Değer: true
Önerilen Değer: true
Timeout ve Connection Pool Parametreleri
Timeout ve Connection Pool Parametreleri
Connection Timeout
Varsayılan: 3000
Min: 1000 | Max: 60000
Birim: milisaniye
Request Timeout
Varsayılan: 3000
Min: 1000 | Max: 120000
Birim: milisaniye
Pool Size
Varsayılan: 10
Min: 1 | Max: 200
Birim: adet
Retry Backoff
Varsayılan: 3000
Min: 100 | Max: 10000
Birim: milisaniye
Kullanım Senaryoları
Gerçek Zamanlı Audit
Çözüm: topicName=audit.events, bootstrap.servers=cluster-prod:9092
Beklenen Davranış: Audit mesajları tek topic’te toplanır, denetim ekibi tek noktadan tüketir
Çoklu Ortam Yönetimi
Çözüm: Environment=Development, Enable Secure=false
Beklenen Davranış: Ortam seçimi ile farklı broker URL’leri yönetilir
Güvenli Üretim Yayını
Çözüm: Enable Secure=true, ProtocolTypes=TLSv1.3, KeyStoreId=ks-prod
Beklenen Davranış: Sertifika doğrulaması sağlanır, mesajlar şifreli gider
Yüksek Trafik Kuyruk
Çözüm: Pool Size=50, linger.ms=5, batch.size=32768
Beklenen Davranış: Üretici batch’leri büyür, throughput artar
Retry Optimizasyonu
Çözüm: retry.backoff.ms=5000, retries=10
Beklenen Davranış: Otomatik yeniden denemeler ile mesaj kaybı yaşanmaz
SLA İzleme (opsiyonel)
Çözüm: delivery.timeout.ms=60000, enable.idempotence=true
Beklenen Davranış: Üretici timeouts loglanır, SLA raporları beslenir
Connection Yapılandırma
Yeni Kafka Oluşturma

Yapılandırma Adımları
Oluşturma Sayfasına Gitme
- Sol menüden Connection → Kafka bölümüne gidin.
- Sağ üstteki [+ Create] butonuna tıklayın.
Temel Bilgileri Girme
- Toggle ile aktif/pasif durumu ayarlayın. Yeni connection’lar varsayılan olarak aktiftir.
- Örnek:
Production_KafkaAudit - Benzersiz isim girin, boşlukla başlamaz.
- Sistem otomatik kontrol eder. Yeşil tik: kullanılabilir. Kırmızı çarpı: mevcut isim.
- Örnek: “Audit topic producer connection”
- Maks. 1000 karakter.
- Connection’ın amacını açıklayın.
Environment (Ortam) Seçimi
- Dropdown menüden ortam seçin: Development, Test, veya Production.
- Her ortam için farklı connection parametreleri tanımlanabilir.
Kafka Spesifik Parametreler - Properties & Topic
- propertiesMap tablosuna broker URL’leri, serializer ayarları ve timeout değerlerini girin.
- Her kayıt için valueType seçmeyi unutmayın; sayı değerlerinde INTEGER kullanın.
- Topic Name alanına bağlanılacak topic’i yazın.
Kafka Spesifik Parametreler - Güvenli Mesajlama
- Enable Secure toggle’ını açarak TLS’i zorunlu kılın.
- Protocol Types alanında desteklenen SSLContext protokollerini seçin.
- KeyStore ve TrustStore seçimlerini yapın veya yeni keystore oluşturun.
Timeout ve Connection Pool Ayarları
- max.block.ms, request.timeout.ms, retry.backoff.ms gibi parametreleri propertiesMap içine ekleyin.
- Trafik hacmine göre linger.ms, batch.size, connections.max.idle.ms gibi ayarları belirleyin.
Güvenlik ve Authentication Ayarları
- SASL/SCRAM kullanılıyorsa sasl.mechanism, sasl.jaas.config anahtarlarını ekleyin.
- Broker sertifikaları için doğru TrustStore seçildiğinden emin olun.
- Hassas credential değerlerini plaintext yerine Secret türü MapValue ile saklayın.
Test Connection
- [Test Connection] butonuna tıklayın.
- Bağlantı parametrelerinin doğru olup olmadığını test edin.
- Başarılı: Yeşil onay mesajı
- Başarısız: Hata detayları gösterilir
Kaydetme
- Sağ üstteki [Save and Deploy] butonuna tıklayın.
- Benzersiz isim
- Zorunlu alanlar dolu
- Test connection başarılı (önerilir)
- Connection listeye eklenir
- Integration Flow ve Connector adımlarında kullanılabilir hale gelir
- Ortama göre aktif olur
Connection’ı Silme
Connection’ı silmek için:Yöntem 1: Liste Ekranından
- Connection listesinde satır sonundaki ⋮ menüsünden Delete seçeneğini tıklayın.
- Onay dialogunda silme işlemini onaylayın.
Silme İpuçları
- Integration Flow veya Connector adımlarında kullanılıyor olabilir.
- Gerekirse alternatif bir connection atayın.
- Silmeden önce Export ile yedek alın.
Alternatif: Deaktif Etme
- Silmek yerine connection’ın aktif durumunu pasif hale getirin.
- Connection pasif olur ancak silinmez.
- Gerektiğinde aktif hale getirerek yeniden kullanabilirsiniz.
Connection’ı Dışa/İçe Aktarma
Dışa Aktarma (Export)
Dışa Aktarma (Export)
Yöntem 1: Liste Ekranından
- Connection listesinde satır sonundaki ⋮ menüsünden Export seçeneğini tıklayın.
- ZIP dosyası otomatik olarak indirilir.
Dosya Formatı
{Date}-kafka-integration-{ConnectionName}-export.zipÖrnek:
13 Nov 2025-kafka-integration-Production_KafkaAudit-export.zipZIP İçeriği
- Connection JSON dosyası
- Metadata bilgileri
- Bağımlılık bilgileri (örneğin sertifikalar, key store)
Kullanım Alanları
- Yedekleme
- Ortamlar arası taşıma (Test → Prod)
- Versiyonlama
- Ekip veya proje bazlı paylaşım
İçe Aktarma (Import)
İçe Aktarma (Import)
İçe Aktarma Adımları
- Ana listede [Import Kafka] butonuna tıklayın.
- İndirilen ZIP dosyasını seçin.
- Sistem kontrolleri: Format geçerli mi? İsim çakışması var mı? Bağımlılıklar mevcut mu?
- Ardından [Import] butonuna tıklayın.
İçe Aktarma Senaryoları
Connection’ın Kullanım Alanları
Connection Oluşturma ve Aktif Etme
- Connection’ı oluşturun.
- Test Connection ile bağlantıyı doğrulayın.
- Save and Deploy ile kaydedin ve etkinleştirin.
- Connection’ın Enabled durumda olduğundan emin olun.
Integration / Connector Adımlarında Kullanım
Scheduled Job Kullanımı
Test Amaçlı Kullanım
Best Practices
Yapılması Gerekenler ve En İyi Uygulamalar
Yapılması Gerekenler ve En İyi Uygulamalar
Topic ve Partition Planlama
İyi: Trafiği partition sayısını artırarak yaymak.
En İyi: Partition planını tüketici sayısı ve throughput ihtiyacına göre per topic belirlemek
PropertiesMap Versiyonlama
İyi: Değişiklikleri manuel takip etmek.
En İyi: propertiesMap değişikliklerini export dosyalarıyla version control altında tutmak
Sertifika Döngüsü Yönetimi
İyi: Manuel takvim tutmak.
En İyi: Secret Manager event’leri ve monitoring alarmlarıyla sertifika yenilemelerini otomatik planlamak
Monitoring ve Alerting
İyi: Manuel test yapmak.
En İyi: Connection Monitoring metriklerini APM/Prometheus ile takip edip otomatik alarm üretmek
Ortam Yönetimi
İyi: Her ortam için ayrı connection oluşturmak.
En İyi: Environment seçeneğini kullanarak tek connection’da tüm ortamları yönetmek, ortamlar arası geçişte sadece environment değiştirmek
Connection Test
İyi: Kaydetmeden önce Test Connection ile doğrulamak.
En İyi: Her parametre değişikliğinden sonra test etmek, production’a geçmeden önce test ortamında tam entegrasyon testi yapmak
Güvenlik En İyi Uygulamaları
Güvenlik En İyi Uygulamaları
SASL Yapılandırması
Broker Erişim Segmentasyonu
Log Masking
Kimlik Bilgileri Yönetimi
SSL/TLS Kullanımı
Erişim Kontrolü
Kaçınılması Gerekenler
Kaçınılması Gerekenler
Tek Broker URL'si Kullanmamak
Alternatif: Birden fazla bootstrap.servers adresi tanımlayın
Serializer Tiplerini Yanlış Seçmek
Alternatif: Key/Value serializer’ları mesaj formatına göre belirleyin
SASL Parametrelerini Plaintext Tutmak
Alternatif: Secret MapValue kullanın
Production Connection'ı Test Ortamında Kullanma
Alternatif: Her ortam için ayrı connection oluşturun, environment parametresini kullanın, connection isimlerini ortama göre prefix ekleyerek ayırın (Test_, Prod_)
Çok Düşük Timeout Değerleri
Alternatif: Gerçek kullanım senaryolarına göre timeout değerlerini ayarlayın, network latency’yi ölçün ve timeout’ları buna göre belirleyin
Connection Pool Kullanmama
Alternatif: Connection pool aktif edin, pool size’ı trafik hacmine göre ayarlayın, pool monitoring kurun
Performans İpuçları
Performans İpuçları
Batch Boyutu
Etki: Daha az ağ çarpışı ile throughput artar
Sıkıştırma
Etki: Broker üzerindeki bant genişliği azalır
Async Send Kullanımı
Etki: İstemci bekleme süresi kısalır
Connection Pool Optimizasyonu
Etki: Bağlantı açma maliyeti %80 azalır, yanıt süreleri düşer, kaynak kullanımı optimize edilir
Timeout Değerleri Optimizasyonu
Etki: Gereksiz beklemeler önlenir, hızlı fail-over sağlanır, kullanıcı deneyimi iyileşir
Connection Monitoring
Etki: Sorunlar proaktif tespit edilir, performans darboğazları erken belirlenir, kesinti süresi azalır
Sorun Giderme (Troubleshooting)
Topic Bulunamadı
Topic Bulunamadı
Topic Adı
Topic Durumu
ACL İzinleri
Broker Authentication Hatası
Broker Authentication Hatası
SASL Güncelleme
Sertifika Kontrolü
TrustStore Kontrolü
Connection Timeout
Connection Timeout
Network Kontrolü
Sistem Sağlığı
Timeout Ayarları
Log İnceleme
Authentication Failed
Authentication Failed
Kimlik Bilgileri
Kullanıcı Durumu
Yetki Kontrolü
Sertifika Kontrolü
Pool Exhausted
Pool Exhausted
Pool Size
Connection Kontrolü
Idle Timeout
Metrik İzleme
Connection Test Başarılı Ama Entegrasyon Akışı Hata Veriyor
Connection Test Başarılı Ama Entegrasyon Akışı Hata Veriyor
Enable Toggle
Connection Seçimi
Connection Deploy
Flow/Job Deploy
Log Kontrolü
Sık Sorulan Sorular (SSS)
Kafka Connection ile birden fazla topic yönetebilir miyim?
Kafka Connection ile birden fazla topic yönetebilir miyim?
Enable Secure kapalı bırakılabilir mi?
Enable Secure kapalı bırakılabilir mi?
PropertiesMap'e secret değerleri nasıl eklenir?
PropertiesMap'e secret değerleri nasıl eklenir?
Multi-broker yapılandırmasında sıralama önemli mi?
Multi-broker yapılandırmasında sıralama önemli mi?
Test Connection başarısızsa Deployment yapabilir miyim?
Test Connection başarısızsa Deployment yapabilir miyim?
Aynı connection'ı birden fazla Integration Flow'da kullanabilir miyim?
Aynı connection'ı birden fazla Integration Flow'da kullanabilir miyim?
Connection pool kullanmak zorunlu mudur?
Connection pool kullanmak zorunlu mudur?
Test ve Production için farklı connection'lar mı oluşturmalıyım?
Test ve Production için farklı connection'lar mı oluşturmalıyım?
Test Connection başarılı ama Integration Flow'da çalışmıyor, neden?
Test Connection başarılı ama Integration Flow'da çalışmıyor, neden?
- Connection enable toggle’ı pasif olabilir
- Integration adımında farklı bir connection seçili olabilir
- Connection deploy edilmemiş olabilir
- Integration Flow henüz redeploy edilmemiş olabilir

