ApsaraMQ for Kafka:Bağlayıcıları yönetin

Ön koşullar

Aşağıdaki bağlayıcılardan birini oluşturdunuz:

• Function Compute havuz bağlayıcısı oluşturma

• MaxCompute havuz bağlayıcısı oluşturma

• OSS havuz bağlayıcısı oluşturma

• Elasticsearch havuz bağlayıcısı oluşturma

• MySQL kaynak bağlayıcısı oluşturma

• Tablestore havuz bağlayıcısı oluşturma

• AnalyticDB havuz bağlayıcısı oluşturma

Notlar

• Yalnızca Function Compute havuz bağlayıcılarının ve MySQL kaynak bağlayıcılarının yapılandırmalarını değiştirebilirsiniz.

• Bir bağlayıcıyı yalnızca Çalışıyor durumundayken askıya alabilirsiniz. Bir bağlayıcıyı yalnızca Askıda durumundayken etkinleştirebilirsiniz.

Bağlayıcı yapılandırmalarını görüntüleyin

Bir bağlayıcının temel bilgilerini, kaynak bilgilerini ve hedef bilgilerini görüntüleyin.

1. ApsaraMQ for Kafka konsolu nda oturum açın.

2. Overview sayfasında, Resource Distribution bölümünden bir bölge seçin.

3. Sol gezinme bölmesinde Connectors öğesine tıklayın.

4. Connectors sayfasında, Select Instance açılır listesinden bağlayıcının ait olduğu örneği seçin. Listede bağlayıcıyı bulun ve Actions sütununda Details seçeneğine tıklayın.

   Bağlayıcı ayrıntıları sayfasında bağlayıcının Basic Information, Source Information ve Destination Information bilgilerini görüntüleyebilirsiniz.

Bağlayıcı günlüklerini görüntüleyin

Bir bağlayıcı sorununu gidermeniz gerekiyorsa, Message Queue for Apache Kafka konsolunda ilgili günlükleri görüntüleyebilirsiniz.

1. ApsaraMQ for Kafka konsolu nda oturum açın.

2. Overview sayfasında, Resource Distribution bölümünden bir bölge seçin.

3. Sol gezinme bölmesinde Connectors öğesine tıklayın.

4. Connectors sayfasında, Select Instance açılır listesinden bağlayıcının ait olduğu örneği seçin. Listede hedef bağlayıcıyı bulun. Actions sütununda More > View Logs seçeneğini belirleyin.

   Alternatif olarak, hedef bağlayıcının adına tıklayabilir veya Actions sütununda Details seçeneğine tıklayabilirsiniz. Bağlayıcı ayrıntıları sayfasında sağ üst köşede bulunan View Logs seçeneğine tıklayın.

   Not

   Actions sütunundaki View Logs konumu görev durumuna bağlıdır. Gerçek kullanıcı arayüzü gösterimi esas alınmalıdır.

   Bağlayıcı günlükleri sayfasında bağlayıcının günlüklerini görüntüleyebilirsiniz.

Bağlayıcı yapılandırmalarını değiştirin

Bir Function Compute havuz bağlayıcısı veya MySQL kaynak bağlayıcısı oluşturduktan sonra, Message Queue for Apache Kafka konsolunda yapılandırmasını değiştirebilirsiniz.

1. ApsaraMQ for Kafka konsolu nda oturum açın.

2. Overview sayfasında, Resource Distribution bölümünden bir bölge seçin.

3. Sol gezinme bölmesinde Connectors öğesine tıklayın.

4. Connectors sayfasında, Select Instance açılır listesinden bağlayıcının ait olduğu örneği seçin. Listede hedef bağlayıcıyı bulun. Actions sütununda More > Modify Configuration seçeneğini belirleyin.

   Alternatif olarak, hedef bağlayıcının adına tıklayabilir veya Actions sütununda Details seçeneğine tıklayabilirsiniz. Bağlayıcı ayrıntıları sayfasında sağ üst köşede bulunan Modify Configuration seçeneğine tıklayın.

5. Modify Configuration panelinde, yapılandırma parametrelerini ihtiyaca göre değiştirin ve ardından OK seçeneğine tıklayın.

   • Function Compute havuz bağlayıcısı için yapılandırmaları değiştirme

     Parametre	Açıklama
     Consumer Thread Concurrency	Kaynak konu için eşzamanlı tüketici iş parçacığı sayısı. Varsayılan değer 6'dır. Geçerli değerler: 1 2 3 6 12
     Failure Handling Policy	Bir konu bölümüne mesaj teslimi başarısız olduğunda alınacak eylemi belirler. Geçerli değerler: Continue Subscription: Hatanın oluştuğu bölümden tüketmeye devam eder ve hatayı günlüğe kaydeder. Stop Subscription: Hatanın oluştuğu bölümden tüketmeyi durdurur ve hatayı günlüğe kaydeder. Not Günlükleri görüntüleme hakkında daha fazla bilgi için bkz. Bağlayıcıları yönetme. Hata kodlarına dayalı çözümleri bulma hakkında daha fazla bilgi için bkz. Hata kodu listesi.
     Transmission Mode	Mesaj gönderme modu. Geçerli değerler: Synchronous: Gönderen ve alıcı aynı anda çalışıyor ve iletişim için hazır olmalıdır. Asynchronous: Gönderen, bir mesaj gönderdikten sonra sunucudan yanıt beklemeden diğer görevlere devam edebilir.
     Data Size	Toplu iş olarak gönderilecek mesaj sayısı. Varsayılan değer 20'dir. Değer aralığı [1, 5000]'dir.
     Retries	Bir mesaj gönderilemediğinde yapılacak yeniden deneme sayısı. Varsayılan değer 2'dir. Değer aralığı 1 ila 3'tür. Mesaj gönderiminin başarısız olmasına neden olan bazı hatalar için yeniden denemeler desteklenmez. Hata kodları hakkında daha fazla bilgi için bkz. Hata kodu listesi. Farklı hata kodları için yeniden deneme desteği aşağıda açıklanmıştır: 4xx: 429 hata kodu hariç, yeniden denemeler desteklenmez. 5xx: Yeniden denemeler desteklenir. Not Bağlayıcı, Function Compute'a mesaj göndermek için InvokeFunction API'sini çağırır.

   • MySQL kaynak bağlayıcısı için yapılandırmaları değiştirme

     Parametre

     Açıklama

     Database Table

     Eşitlenecek ApsaraDB RDS for MySQL örneğindeki bir veya daha fazla tablonun adı. Birden çok tablo adını virgül (,) ile ayırın. Bir veritabanı tablosu ile bir hedef konu arasında bire bir eşleme vardır. Not Mevcut bir görev için tablo eklerseniz veya değiştirirseniz, önceden Message Queue for Apache Kafka konsolunda karşılık gelen bir Topic oluşturmanız gerekir. Topic adı Topic ön eki_tablo adı formatında olmalıdır. Aksi takdirde çalışma zamanı hatası oluşur. Daha fazla bilgi için bkz. Adım 1: Topic Oluşturma.

   Değişiklik tamamlandıktan sonra, Connectors sayfasında hedef Bağlayıcıyı bulun. Actions sütununda Details seçeneğine tıklayın. Connector Details sayfasında güncellenmiş Bağlayıcı yapılandırmasını görüntüleyebilirsiniz.

Bir bağlayıcıyı askıya alın veya etkinleştirin

Message Queue for Apache Kafka konsolunda çalışan bir bağlayıcıyı geçici olarak durdurmak için askıya alabilir veya askıya alınmış bir bağlayıcıyı yeniden başlatmak için etkinleştirebilirsiniz.

1. ApsaraMQ for Kafka konsolu nda oturum açın.

2. Overview sayfasında, Resource Distribution bölümünden bir bölge seçin.

3. Sol gezinme bölmesinde Connectors öğesine tıklayın.

4. Connectors sayfasında, Select Instance açılır listesinden bağlayıcının ait olduğu örneği seçin. Listede hedef bağlayıcıyı bulun ve ardından ihtiyaca göre askıya alın veya etkinleştirin.

   • Bir bağlayıcıyı askıya almak için: Actions sütununda More > Suspend seçeneğini belirleyin. Note iletişim kutusunda askıya almayı onaylayın ve OK seçeneğine tıklayın.

   • Bir bağlayıcıyı etkinleştirmek için: Actions sütununda Enable seçeneğine tıklayın. Note iletişim kutusunda başlatmayı onaylayın ve OK seçeneğine tıklayın.

   Alternatif olarak, hedef bağlayıcının adına tıklayabilir veya Actions sütununda Details seçeneğine tıklayabilirsiniz. Bağlayıcı ayrıntıları sayfasında sağ üst köşede bulunan Suspend veya Enable seçeneğine tıklayın.

   Connectors sayfasında askıya aldığınız veya etkinleştirdiğiniz bağlayıcıyı bulun. Status değeri Suspended veya Running olarak değişir.

   Not

   Bir MySQL kaynak bağlayıcı görevi uzun süre askıda kalırsa yeniden başlatılamayabilir. Bu durumda, görevi bulun ve Actions sütununda Task Configurations seçeneğine tıklayın. DataWorks sayfasında hedef eşitleme görevinin satırını bulun ve Start seçeneğine tıklayın. Start iletişim kutusunda Reset Offset seçeneğini belirleyin, Start Time Point değerini yapılandırın ve ardından OK seçeneğine tıklayın.

Bir bağlayıcıyı test edin

Message Queue for Apache Kafka konsolundan bir bağlayıcıyı doğrulamak için test mesajı gönderebilirsiniz.

1. ApsaraMQ for Kafka konsolu nda oturum açın.

2. Overview sayfasında, Resource Distribution bölümünden bir bölge seçin.

3. Sol gezinme bölmesinde Connectors öğesine tıklayın.

4. Connectors sayfasında, Select Instance açılır listesinden bağlayıcının ait olduğu örneği seçin. Listede hedef bağlayıcıyı bulun ve ardından Actions sütununda Test seçeneğine tıklayın.

   Alternatif olarak, hedef bağlayıcının adına tıklayabilir veya Actions sütununda Details seçeneğine tıklayabilirsiniz. Bağlayıcı ayrıntıları sayfasında sağ üst köşede bulunan Test seçeneğine tıklayın.

   Not

   Actions sütunundaki Test konumu görevin durumuna bağlı olarak değişebilir.

5. Send Message panelinde bir test mesajı gönderin.

   1. Message Key metin kutusuna demo gibi bir mesaj anahtarı girin.

   2. Message Content metin kutusuna test mesajının içeriğini girin, örneğin {"key": "test"}.

   3. Mesajın belirli bir bölüme gönderilip gönderilmeyeceğini kontrol etmek için Send to Specified Partition seçeneğini kullanın.

      • Yes seçeneğine tıklayın ve Partition ID metin kutusuna 0 gibi bir bölüm kimliği girin. Bölüm kimliğini sorgulamak için bkz. Bölüm durumunu görüntüleme.

      • Bir bölüm belirtmek istemiyorsanız No seçeneğine tıklayın.

Tüketim ilerlemesini görüntüleyin

Bir bağlayıcı çalışmaya başladıktan sonra, kaynak konu için consumer group tüketim durumunu görüntüleyebilirsiniz. consumer group adı connect-{task_name} şeklindedir.

1. ApsaraMQ for Kafka konsolu nda oturum açın.

2. Overview sayfasında, Resource Distribution bölümünden bir bölge seçin.

3. Sol gezinme bölmesinde Connectors öğesine tıklayın.

4. Connectors sayfasında, Select Instance açılır listesinden bağlayıcının ait olduğu örneği seçin. Listede hedef bağlayıcıyı bulun ve ardından Actions sütununda Consumption Progress seçeneğine tıklayın.

   Alternatif olarak, hedef bağlayıcının adına tıklayabilir veya Actions sütununda Details seçeneğine tıklayabilirsiniz. Bağlayıcı ayrıntıları sayfasında sağ üst köşede bulunan Consumption Progress seçeneğine tıklayın.

   consumer group tüketim ayrıntıları panelinde, bağlayıcı görevinin kaynak konuda kullandığı consumer group tüketim ayrıntılarını görüntüleyebilirsiniz.

Bir bağlayıcıyı silin

Her Message Queue for Apache Kafka örneğinin bağlayıcı sayısı üzerinde bir sınırı vardır. Bir bağlayıcıya artık ihtiyacınız yoksa, Message Queue for Apache Kafka konsolunda bu bağlayıcıyı silebilirsiniz.

1. ApsaraMQ for Kafka konsolu nda oturum açın.

2. Overview sayfasında, Resource Distribution bölümünden bir bölge seçin.

3. Sol gezinme bölmesinde Connectors öğesine tıklayın.

4. Connectors sayfasında, Select Instance açılır listesinden bağlayıcının ait olduğu örneği seçin. Listede hedef bağlayıcıyı bulun. Actions sütununda More > Delete seçeneğini belirleyin.

   Alternatif olarak, hedef bağlayıcının adına tıklayabilir veya Actions sütununda Details seçeneğine tıklayabilirsiniz. Bağlayıcı ayrıntıları sayfasında sağ üst köşede bulunan Delete seçeneğine tıklayın.

5. Note iletişim kutusunda bağlayıcıyı silmek için OK seçeneğine tıklayın.