Yüksek verimli, hataya dayanıklı veri boru hatları için Apache Kafka'ya kurumsal sınıf olay akışı dışa aktarımı. SASL kimlik doğrulamasını ve yapılandırılabilir onayları (acks) destekler.
open_in_new
Resmi Dokümantasyon
kafka.apache.org
Konfigürasyon Parametreleri
| Parametre | Zorunlu | Tip | Varsayılan | Açıklama |
|---|---|---|---|---|
| BootstrapServers | Evet | string | - | Virgülle ayrılmış Kafka broker listesi. |
| Topic | Evet | string | - | Hedef Kafka konusu. |
| SaslMechanism | Hayır | string | Plain | SASL mekanizması: Plain, ScramSha256, ScramSha512, OAuthBearer. |
| SaslUsername | Hayır | string | (boş) | SASL kullanıcı adı. |
| SaslPassword | Hayır | string | (boş) | SASL şifresi. |
| SecurityProtocol | Hayır | string | Plaintext | Güvenlik protokolü: Plaintext, Ssl, SaslPlaintext, SaslSsl. |
İç Davranış
Üretici (Producer) Garantileri
- Teslimat: Yapılandırmaya bağlı olarak 'En az bir kez' (At-least-once) anlambilimi için yapılandırılabilir.
- Bölümleme (Partitioning): Mesajları cihaz ID'sine veya rastgele (Round Robin) göre böler.
Performans Özellikleri
- Asenkron Üretim: Engellemeyen (non-blocking) G/Ç için Confluent Kafka .NET istemcisini kullanır.
- Toplu İşlem: Kafka üreticisi, verimi artırmak ve ağ gidiş-gelişlerini azaltmak için mesajları dahili olarak gruplar.