# Kafka Hedef

Bu konuda, Kafka hedef bağlayıcısı kullanılarak bir Kafka hedefine bağlantının nasıl yapılandırılacağı açıklanmaktadır. Kafka sadece çoğaltma görevlerinde hedef olarak kullanılabilir.

Hedef olarak Kafka ayarlamak şunları içerir:

* [Ön koşulların](https://help.qlik.com/tr-TR/cloud-services/Subsystems/Hub/Content/Sense_Hub/DataIntegration/TargetConnections/kafka-target.htm#Prerequi) yerine getirilmesi
* öğesine bağlantı yapılandırmaKafka

## Bağlantı özelliklerini ayarlama

Bağlayıcıyı yapılandırmak için aşağıdakileri yapın:

1. Bağlantılar'da Bağlantı oluştur'a tıklayın.

2. Kafka hedef bağlayıcısını seçin ve ardından aşağıdaki ayarları sağlayın:

### Veri hedefi

#### Veri ağ geçidi

Bilgi notuData Movement gateway bu abonelik kademesiyle desteklenmediğinden bu alan, Qlik Talend Cloud Başlangıç Kılavuzu aboneliğiyle kullanılamaz.

Verileri Amazon MSK'ya taşırken, bir Data Movement gateway yalnızca Amazon MSK'ya Qlik Cloud öğesinden erişilemiyorsa ve yalnızca bir Özel Bağlantı kullanılarak erişilebiliyorsa gereklidir (örneğin, bir Sanal Özel Bulutta bulunuyorsa). Bu durumda, hedef veritabanına erişmek istediğiniz Data Movement gateway öğesini seçin. Kullanım durumunuza bağlı olarak, bu ya veri kaynağından veri taşımak için dağıtılanData Movement gateway ile aynı ya da farklı bir veri kaynağı olacaktır.

Verileri Qlik Cloud konumundan doğrudan erişilebilen bir Amazon MSK örneğine taşıyorsanız, Yok öğesini seçin.

Bilgi notu

* Verileri şirket içi Kafka'ya taşıyorsanız (aşağıdaki Bulut sağlayıcı bölümüne bakın), Kafka'ya Qlik Cloud konumundan doğrudan erişilip erişilemediğine bakılmaksızın bir Data Movement gateway seçmelisiniz.

* Data Movement gateway kullanmanız gerekiyorsa, 2025.5.40 veya sonraki bir sürüm gereklidir.

Data Movement gateway kullanım durumları hakkında bilgi için bkz. [Ne zaman Data Movement gateway gereklidir?](https://help.qlik.com/tr-TR/cloud-services/Subsystems/Hub/Content/Sense_Hub/Gateways/replication-gateway.htm#top) ve [Yaygın kullanım durumları](https://help.qlik.com/tr-TR/cloud-services/Subsystems/Hub/Content/Sense_Hub/Gateways/replication-gateway.htm#Common).

#### Bulut sağlayıcı

Şirket içinde Kafka kullanmak için Yok seçeneğini veya Amazon MSK kullanmak için Amazon MSK seçeneğini seçin.

#### Aracı sunucular

Bir veya daha fazla aracı sunucuyu aşağıdaki biçimi kullanarak belirtin (yüksek kullanılabilirlik için):

`server1[:port1][,server2[:port2]]`

**Örnek:**

`192.168.1.100:9092,192.168.1.101:9093`

Veri görevi, ilk uygun ana bilgisayara bağlanacaktır. Bir ana bilgisayar bağlantı noktası belirtilmeden belirtilirse, 9092 numaralı bağlantı noktası varsayılan olarak kullanılacaktır.

Bilgi notu

SSL veya Kerberos kimlik doğrulaması kullanırken, aracı FQDN'sini (yani IP adresi değil) belirtmeniz gerekir.

Bilgi notu

Kümenizdeki tüm aracı sunucularının Data Movement gateway makinesinden erişilebilir olması gerekir. Ancak, tüm sunucuları belirtmenize gerek yoktur **Aracı sunucuları** alanına yapıştırın. Bunun nedeni, Data Movement gateway kümedeki diğer sunucuların Bağlantı ayrıntılarını almak için yalnızca sunuculardan birine bağlanması gerektiğidir. Bu nedenle, görev çalıştırıldığında en yüksek olasılıkla kullanılabilir olacak sunucuları belirtmek en iyi uygulamadır. Veri görevinin mesaj ürettiği sunucular, konu ve bölümleme konusu ile bölümleme ayarlarına göre belirlenir.

### Hesap özellikleri

#### Kimlik Doğrulama yöntemi

Şunlardan birini seçin:

* **Yok:** Kimlik doğrulama yok.

  Bilgi notu

  Seçilen Bulut sağlayıcısı Amazon MSK olduğunda kullanılamaz.

* **Sertifika**: Bu seçeneği belirlerseniz, aşağıdaki bilgileri de sağlamanız gerekir:

  **Not**Genel ve özel anahtar dosyaları PEM biçiminde olmalıdır.

  * **Genel anahtar dosyası:** PEM biçimindeki ortak anahtar dosyasına göz atın. Kaydet öğesine tıkladığınızda, dosya Qlik Talend Cloud konumuna yüklenecek ve bağlayıcı ayarlarında seçilen Data Movement gateway konumuna dağıtılacaktır.
  * **Özel anahtar dosyası**: PEM biçimindeki özel anahtar dosyasına göz atın. Kaydet'e tıkladığınızda, dosya Qlik Talend Cloud'e yüklenecek ve bağlayıcı ayarlarında seçilen Data Movement gateway'e dağıtılacaktır.
  * **Özel anahtar parolası**: Özel anahtar dosyasının parolası.

* Kerberos (SASL/GSSAPI): Kafka kümesine Kerberos kullanarak kimlik doğrulaması yapmak için seçin.

  Bilgi notu

  Seçilen Bulut sağlayıcısı Amazon MSK olduğunda bu kimlik doğrulama yöntemi kullanılamaz.

  * Asıl: Aracı sunucusuna/sunucularına karşı kimlik doğrulaması yapmak için kullanılan Kerberos asılı.
  * Keytab dosyası: Keytab dosyasına göz atın. Kaydet'e tıkladığınızda, dosya Qlik Talend Cloud konumuna yüklenecek ve bağlayıcı ayarlarında seçilen Data Movement gateway konumuna dağıtılacaktır.

  Bilgi notu

  Linux'ta Kerberos kimlik doğrulamasını kullanmak için, Kerberos istemci (iş istasyonu) paketi yüklenmelidir.

* Kullanıcı adı ve parola (SASL/PLAIN): Kendinizi bir kullanıcı adı ve parola (SASL/PLAIN) kullanarak doğrulamak için bu seçeneği belirleyebilirsiniz. Parolanın açık metin olarak gönderilmesini önlemek için, TLS'yi Etkinleştir seçeneğini de etkinleştirmeniz şiddetle tavsiye edilir.

  Bilgi notu

  Seçilen Bulut sağlayıcısı Amazon MSK olduğunda bu kimlik doğrulama yöntemi kullanılamaz.

* Kullanıcı Adı ve Parola (SASL/SCRAM-SHA-256): Kendinizi bir kullanıcı adı ve parola (SASL/SCRAM-SHA-256) kullanarak doğrulamak için bu seçeneği belirleyebilirsiniz.

  Bu seçeneği belirlemenin, her bir aracının `server.properties` dosyasının ilgili SASL/SCRAM mekanizmasıyla yapılandırılmasını da gerektirdiğini unutmayın.

  Bilgi notu

  Seçilen Bulut sağlayıcısı Amazon MSK olduğunda bu kimlik doğrulama yöntemi kullanılamaz.

* Kullanıcı Adı ve Parola (SASL/SCRAM-SHA-512): Kendinizi bir kullanıcı adı ve parola (SASL/SCRAM-SHA-512) kullanarak doğrulamak için bu seçeneği belirleyebilirsiniz.

  Bu seçeneği belirlemenin, her bir aracının `server.properties` dosyasının ilgili SASL/SCRAM mekanizmasıyla yapılandırılmasını da gerektirdiğini unutmayın.

#### SSL seçenekleri

[](https://help.qlik.com/en-US/cloud-services/Subsystems/Hub/Content/Sense_Hub/DataIntegration/TargetConnections/kafka-target.htm)TLS'yi Etkinleştir (TLS 1.0, 1.1 ve 1.2'yi destekler)

Qlik Talend Cloud ile aracı sunucu(lar) arasındaki iletişimi şifrelemek için bu seçeneği belirleyin. Aracılar SSL gerektirecek şekilde yapılandırılmışsa, o zaman bu seçeneği *mutlaka* belirlemelisiniz.

* CA dosyası: PEM biçimindeki CA sertifikasına göz atın. Kaydet'e tıkladığınızda, dosya Qlik Talend Cloud konumuna yüklenecek ve bağlayıcı ayarlarında seçilen Data Movement gateway konumuna dağıtılacaktır.

  Bilgi notu

  Seçilen Bulut sağlayıcısı Amazon MSK olduğunda gerekli değildir.

### Meta veri mesajı yayınlama

#### Şema kayıt defteri, meta veri mesajı yayınlamak için kullanılabilir olacaktır

Açılır listeden aşağıdakilerden birini seçin:

* Hayır

  Bu seçenek belirlendiğinde, yalnızca veri mesajları yayınlanacaktır.

* Confluent şema kayıt defteri

  Bu seçeneği belirlerseniz, ayrıca aşağıda açıklanan Şema kayıt defteri bağlantı özelliklerini yapılandırmanız gerekir.

  Uyarı notuConfluent şema kayıt defteri seçildiğinde, aşağıdaki [dahili özelliği](https://help.qlik.com/tr-TR/cloud-services/Subsystems/Hub/Content/Sense_Hub/DataIntegration/TargetConnections/kafka-target.htm#internal_prop) ayarlamanız gerekir: CsrSkipGlobalConfig=false

Bilgi notu

* Confluent Şema kayıt defteri seçenekleri yalnızca Avro mesaj biçimini destekler.

* Şema mesajlarını veri mesajlarıyla aynı konuya yayınlamamanız *şiddetle* tavsiye edilir.

* Konular mevcut değilse, veri görevinin çalışma zamanında konuları oluşturmasını sağlamak için aracıları `auto.create.topics.enable=true` ile yapılandırın. Aksi takdirde görev başarısız olacaktır.

#### Mesaj biçimi

Mesaj formatı olarak JSON veya Avro seçin. Confluent şema kayıt defteri seçtiyseniz, Avro tek kullanılabilir seçenek olacaktır.

### Şema kayıt defteri bağlantı özellikleri

#### Şema kayıt defteri sunucuları

Yüksek erişilebilirlik için bir veya daha fazla Şema Kayıt Defteri sunucusunu aşağıdaki formatı kullanarak belirtin:

Veri şemalarını Confluent Şema Kayıt Defteri'ne yayımlarken:

` server1:port1[,server2[:port2]]
                 `

Örnek:

` 192.168.1.100:8081,192.168.1.101:8081
                 `

Veri görevi, ilk uygun ana bilgisayara bağlanacaktır.

#### Kimlik Doğrulama yöntemi

Aşağıdaki Şema Kayıt kimlik doğrulama seçeneklerinden birini seçin:

* Yok: Kimlik doğrulama yok.

* Sertifika: Sertifika kullanarak kimlik doğrulaması yapmak için seçin.

  Bu seçeneği belirlerseniz, aşağıdaki bilgileri de sağlamanız gerekir:

  * Ortak anahtar dosyası: PEM biçimindeki ortak anahtar dosyasına göz atın. Kaydet'e tıkladığınızda, dosya Qlik Talend Cloud'e yüklenecek ve bağlayıcı ayarlarında seçilen Data Movement gateway'e dağıtılacaktır.
  * Özel anahtar dosyası: PEM biçimindeki özel anahtar dosyasına göz atın. Kaydet'e tıkladığınızda, dosya Qlik Talend Cloud'e yüklenecek ve bağlayıcı ayarlarında seçilen Data Movement gateway'e dağıtılacaktır.
  * Özel anahtar parolası: Özel anahtar dosyası parolası.

* Kullanıcı adı ve parola: Kullanıcı adı ve parola ile kimlik doğrulaması yapmak için seçin. Ardından, oturum açma kimlik bilgilerinizi Kullanıcı adı ve parola alanlarına girin.

* Sertifika + Kullanıcı adı ve parola: Hem sertifika hem de kullanıcı adı ve parola kullanarak kimlik doğrulaması yapmak için seçin.

  Bu seçenek belirlendiğinde, yukarıda açıklanan Ortak anahtar dosyası, Özel anahtar dosyası, Özel anahtar parolası, Kullanıcı adı ve Parola alanlarına gerekli bilgileri girin.

* TLS'yi Etkinleştir (TLS 1.0, 1.1 ve 1.2'yi destekler): Data Movement gateway makinesi ile Şema Kayıt Defteri sunucuları arasındaki verileri şifrelemek için bu seçeneği belirleyin. Sunucular SSL gerektirecek şekilde yapılandırılmışsa, bu seçeneği *mutlaka* belirlemelisiniz.

  * CA dosyası: PEM biçimindeki CA sertifikasına göz atın. Kaydet'e tıkladığınızda, dosya Qlik Talend Cloud konumuna yüklenecek ve bağlayıcı ayarlarında seçilen Data Movement gateway konumuna dağıtılacaktır.

[](https://help.qlik.com/en-US/cloud-services/Subsystems/Hub/Content/Sense_Hub/DataIntegration/TargetConnections/kafka-target.htm)

### Dahili özellikler

Dahili özellikler özel kullanım durumları içindir ve bu nedenle diyalog penceresinde gösterilmez. Bunları yalnızca Qlik Desteği tarafından talimat verildiği takdirde kullanmalısınız.

Gerektiği takdirde özellik eklemek veya kaldırmak için alanların sağındaki the Yeni oluştur icon ve the İptal icon düğmelerini kullanın.

### Ad

Bağlantının görünen adı.

## Önkoşullar

Kafka'yı hedef olarak kullanabilmeniz için aşağıdaki ön koşulların karşılanması gerekir:

* [](https://help.qlik.com/en-US/cloud-services/Subsystems/Hub/Content/Sense_Hub/DataIntegration/TargetConnections/kafka-target.htm)Data Movement gateway makinesinden tüm aracılara TCP bağlantı noktalarını açın

* Veri görevinin hedef konulara yazmasını sağlayacak izinleri ayarlayın. Bunu yapmanın bir yolu, Kafka ACL'leri komut dosyasını (kafka-acls) kullanmaktır.

* Veri görevini başlatmadan önce attrep\_apply\_exceptions adında bir konu oluşturun veya aracıları `auto.create.topics.enable=true` ile yapılandırın.

  Unutmayın ki, bu konu mevcut değilse, görev bir veri hatasıyla karşılaştığında, hata işleme politikasından bağımsız olarak her zaman başarısız olur.

  attrep\_apply\_exceptions kontrol tablosunun açıklaması için [İstisnaları uygula](https://help.qlik.com/tr-TR/cloud-services/Subsystems/Hub/Content/Sense_Hub/DataIntegration/Replicating/apply_exceptions.htm) bölümüne bakınız.

## Sınırlamalar ve dikkate alınacak noktalar

Kafka hedef bağlayıcı olarak bir görev tanımlarken, aşağıdaki sınırlamalar geçerlidir:

* Desteklenmeyen görev ayarları:

  * Kafka hedef bağlayıcısı sınırsız LOB boyutunu desteklemez. Görev ayarlarında, LOB sütunlarını dahil et ve sütun boyutunu (KB) ile sınırla seçeneği etkinleştirilecek ve salt okunur olacaktır.

  * Store Changes modu desteklenmemektedir.

  * Toplu iyileştirme uygulama modu desteklenmiyor. Kafka her zaman İşlemsel uygulama modunda çalışır.

  * ALTER'ı Yoksay Değişiklikleri Uygula ayarı, kaynak veri türlerindeki değişiklikler ve tablo yeniden adlandırma için desteklenmiyor.

  * Hedef Tablo Hazırlığı alanının Tabloyu Bırak ve Oluştur seçeneği desteklenmiyor.

  * Hedef Tablo Hazırlığı alanının Yüklemeden önce Kırp seçeneği desteklenmiyor.

  * Değişiklik Verisi Bölümleme Kontrol tablosu desteklenmez.

* Genel sınırlamalar:

  * Kafka konu adları boşluk içeremez veya 255 karakteri (Kafka 0.10'dan itibaren 249) aşamaz ve yalnızca aşağıdaki karakterleri içerebilir:

    a-z|A-Z|0-9|. (nokta)|\_(alt çizgi)|-(eksi)

    Kaynak tablo adları izin verilen maksimum uzunluğu aşarsa veya desteklenmeyen karakterler içeriyorsa, görevi başlatmadan önce adları değiştirmeniz veya genel bir dönüşüm tanımlamanız gerekir.

  * Sütun adları [A-Za-z\_] (harfler veya alt çizgi) ile başlamalı, ardından [A-Za-z0-9\_] (harfler, rakamlar veya alt çizgi) gelmelidir. Örneğin, \_Test\_ geçerli bir sütun adı iken &Test geçerli değildir.

    Bir kaynak sütun adı bu kurala uymuyorsa, sütunu yeniden adlandırmak için bir dönüşüm kullanılmalıdır.

  * Kaynak tabloyu bırakma veya yeniden adlandırma desteklenmez.

## Veri türleri

Aşağıdaki tabloda Qlik Cloud kullanırken desteklenen Kafka veri türleri ve Qlik Cloud veri türlerine ait varsayılan eşleme gösteriliyor.

Bilgi notu

JSON mesaj biçimi kullanılırken, ikili değerler onaltılık basamaklar olarak temsil edilir.

Kafka veri eşlemesi

| Qlik Cloud Veri Türleri | Şema Mesajlarında Kafka Hedef Veri Türleri |
| --- | --- |
| DATE | DATE |
| TIME | TIME |
| DATETIME | DATETIME |
| BYTES | BYTES (uzunluk) |
| BLOB | BLOB |
| REAL4 | REAL4 (7) |
| REAL8 | REAL8 (14) |
| INT1 | INT1 (3) |
| INT2 | INT2 (5) |
| INT4 | INT4 (10) |
| INT8 | INT8 (19) |
| UINT1 | UINT1 (3) |
| UINT2 | UINT2 (5) |
| UINT4<br><br>Bilgi notu<br><br>2^31-1'den büyük değerler desteklenmez. | UINT4 (10) |
| UINT8<br><br>Bilgi notu<br><br>2^63-1'den büyük değerler desteklenmez. | UINT8 (20) |
| NUMERIC | NUMERIC (p,s) |
| STRING | STRING (Uzunluk) |
| WSTRING | STRING (Uzunluk) |
| CLOB | CLOB |
| NCLOB | NCLOB |
| BOOLEAN | BOOLEAN (1) |

[](https://help.qlik.com/en-US/cloud-services/Subsystems/Hub/Content/Sense_Hub/DataIntegration/TargetConnections/kafka-target.htm)

## JSON ve Avro'ya Eşleme

Avro mesaj formatı, veri türünün daha hassas bir şekilde temsil edilmesi için mantıksal türler kullanır.

Qlik Cloud veri türleri, Belirli veri türleri için mantıksal veri türlerini kullan onay kutusu seçiliyse yalnızca desteklenen Avro mantıksal veri türlerine eşlenir.

Veri türü eşlemeleri

| Qlik Cloud veri türleri | JSON | Avro Mantıksal veri türleri |
| --- | --- | --- |
| DATE | STRING | DATE<br><br>Bir Avro INT'i açıklar. |
| TIME | STRING | TIME-MILLIS<br><br>Bir Avro INT'i açıklar. |
| TIMESTAMP | STRING | TIMESTAMP-MICROS<br><br>Bir Avro LONG'u açıklar. |
| STRING | STRING | - |
| WSTRING | STRING | - |
| CLOB | STRING | - |
| NCLOB | STRING | - |
| NUMERIC | STRING | DECIMAL (p,s)<br><br>Bir Avro BYTES'a açıklama ekler. |
| BYTES | BYTES | - |
| BLOB | BYTES | - |
| REAL4 | FLOAT | - |
| REAL8 | DOUBLE | - |
| INT1 | INT | - |
| INT2 | INT | - |
| INT4 | INT | - |
| UINT1 | INT | - |
| UINT2 | INT | - |
| UINT4 | LONG | - |
| INT8 | LONG | - |
| UINT8 | STRING | DECIMAL (20,0)<br><br>Bir Avro BYTES'a açıklama ekler. |
| BOOLEAN | BOOLEAN | - |