Tüm Ürünler
Search

Bu Ürün

    ApsaraMQ for Kafka:FC sink connector oluşturma

    Belge Merkezi

    ApsaraMQ for Kafka:FC sink connector oluşturma

    Son Güncelleme:Oct 06, 2026

    ApsaraMQ for Kafka örneğinizdeki bir kaynak konudan verileri bir Function Compute işlevine aktarmak için bir Function Compute sink connector oluşturun.

    Ön koşullar

    Bir Function Compute sink connector oluşturmadan önce aşağıdaki ön koşulların karşılandığından emin olun:

    • ApsaraMQ for Kafka

      • ApsaraMQ for Kafka örneği için connector özelliğini etkinleştirin. Daha fazla bilgi için bkz. Connector'ü etkinleştirme.

      • ApsaraMQ for Kafka örneği için bir kaynak konu oluşturun. Daha fazla bilgi için bkz. Adım 1: Konu oluşturma.

        Bu örnekte fc-test-input adlı bir konu kullanılmaktadır.

    • Function Compute

      • Function Compute'de bir işlev oluşturun. Daha fazla bilgi için bkz. İşlev oluşturma.

        Önemli

        İşlev bir olay işlevi olmalıdır.

        Bu kılavuzda örnek olarak hello_world adlı bir olay işlevi kullanılmıştır. İşlev guide-hello_world hizmetindedir ve Python çalışma zamanı ortamında çalışır. İşlevin örnek kodu aşağıdadır:

        # -*- coding: utf-8 -*-
import logging
# To enable the initializer feature
# Implement the initializer function as follows:
# def initializer(context):
#   logger = logging.getLogger()
#   logger.info('initializing')
def handler(event, context):
  logger = logging.getLogger()
  logger.info('hello world:' + bytes.decode(event))
  return 'hello world:' + bytes.decode(event)

    • İsteğe bağlı: EventBridge

      Not

      Bu adım yalnızca ApsaraMQ for Kafka örneğiniz Çin (Hangzhou) veya Çin (Chengdu) bölgesindeyse gereklidir.

    Notlar

    • Bir ApsaraMQ for Kafka örneğindeki bir kaynak konudan verileri yalnızca aynı bölgedeyse Function Compute içindeki bir işleve aktarabilirsiniz. Connector sınırlamaları hakkında daha fazla bilgi için bkz. Sınırlamalar.

    • ApsaraMQ for Kafka örneğiniz Çin (Hangzhou) veya Çin (Chengdu) bölgesindeyse connector EventBridge üzerinde dağıtılır.

      • EventBridge şu anda ücretsizdir. Daha fazla bilgi için bkz. Faturalama.

      • Bir connector oluştururken EventBridge aşağıdaki hizmet bağlantılı rollerini otomatik olarak oluşturur: AliyunServiceRoleForEventBridgeSourceKafka ve AliyunServiceRoleForEventBridgeConnectVPC.

        • Hizmet bağlantılı bir rol henüz oluşturulmadıysa EventBridge sizin için ilgili hizmet bağlantılı rolünü otomatik olarak oluşturur; böylece EventBridge bu rolü kullanarak ApsaraMQ for Kafka ve VPC'ye erişebilir.

        • Bu hizmet bağlantılı rolleri zaten varsa EventBridge bunları tekrar oluşturmaz.

        Hizmet bağlantılı rolleri hakkında daha fazla bilgi için bkz. hizmet bağlantılı rolleri.

      • Şu anda EventBridge üzerinde dağıtılan görevlerin çalışma zamanı günlüklerini görüntüleyemezsiniz. Bir connector görevi tamamlandıktan sonra kaynak konunun consumer group tüketim durumunu görüntüleyerek ilerlemesini kontrol edebilirsiniz. Ayrıntılar için bkz. Tüketici durumunu görüntüleme.

    Yordam

    Bir Function Compute sink connector kullanarak bir ApsaraMQ for Kafka örneğindeki bir kaynak konudan verileri Function Compute içindeki bir işleve aktarmak için aşağıdaki adımları izleyin:

    1. İsteğe bağlı: Function Compute sink connector için çapraz bölge erişimini etkinleştirin

      Önemli

      Çapraz bölge erişimine ihtiyacınız yoksa bu adımı atlayın.

      Function Compute sink connector için internet erişimini etkinleştirme

    2. İsteğe bağlı: Function Compute sink connector için çapraz hesap erişimini etkinleştirin

      Önemli

      Çapraz hesap erişimine ihtiyacınız yoksa bu adımı atlayın.

    3. İsteğe bağlı: Function Compute sink connector tarafından gereken konuları ve consumer group öğesini oluşturun

      Önemli

      • Konuların ve consumer group adlarını özelleştirmeniz gerekmiyorsa bu adımı atlayabilirsiniz.

      • Function Compute sink connector tarafından gereken bazı konular yerel depolama motorunu kullanmalıdır. ApsaraMQ for Kafka örneğiniz ana sürüm 0.10.2 ise yerel depolamaya sahip konuları manuel olarak oluşturamazsınız. Bu konular otomatik olarak oluşturulmalıdır.

      1. Function Compute sink connector tarafından gereken konuları oluşturma

      2. Function Compute sink connector tarafından gereken consumer group öğesini oluşturma

    4. Function Compute sink connector oluşturma ve dağıtma

    5. Sonuçları doğrulayın

      1. Test mesajı gönderme

      2. İşlev günlüklerini görüntüleme

    FC Sink connector için internet erişimini etkinleştirme

    Bir Function Compute sink connector'un diğer bölgelerdeki Alibaba Cloud hizmetlerine erişmesi gerekiyorsa bunun için internet erişimini etkinleştirmeniz gerekir. Ayrıntılar için bkz. Connector için internet erişimini etkinleştirme.

    Özel ilke oluşturma

    Hedef hesapta Function Compute'a erişim izni veren özel bir ilke oluşturun.

    1. RAM konsolu na oturum açın.

    2. Sol gezinme bölmesinde İzinler > İlkeler seçeneğini belirleyin.

    3. İlkeler sayfasında İlke Oluştur seçeneğine tıklayın.

    4. İlke Oluştur sayfasında ilkeyi yapılandırın.

      1. JSON sekmesinde ilke betiğini girin ve İleri seçeneğine tıklayın.

        Aşağıdaki ilke betiği Function Compute'a erişim izinleri verir:

        {
    "Version": "1",
    "Statement": [
        {
            "Action": [
                "fc:InvokeFunction",
                "fc:GetFunction"
            ],
            "Resource": "*",
            "Effect": "Allow"
        }
    ]
}

      2. Temel Bilgiler altında Ad alanına KafkaConnectorFcAccess değerini girin.

      3. Tamam seçeneğine tıklayın.

    RAM rolü oluşturma

    Hedef hesapta bir RAM rolü oluşturun. RAM rolü oluştururken güvenilir hizmet olarak ApsaraMQ for Kafka seçilemez. Bu nedenle başka bir desteklenen hizmeti seçmeli ve rol oluşturulduktan sonra güven ilkesini manuel olarak değiştirmelisiniz.

    1. Sol gezinme bölmesinde Kimlik Yönetimi > Roller seçeneğini belirleyin.

    2. Roller sayfasında Rol Oluştur seçeneğine tıklayın.

    3. Rol Oluştur panelinde rolü yapılandırın.

      1. Güvenilen varlık türü olarak Alibaba Cloud Hizmeti seçeneğini belirleyin ve İleri seçeneğine tıklayın.

      2. Rol Türü bölümünde Normal Hizmet Rolü seçeneğini belirleyin. Rol Adı alanına AliyunKafkaConnectorRole değerini girin. Güvenilen Hizmet Seç açılır listesinden Function Compute seçeneğini belirleyin ve ardından Tamamla seçeneğine tıklayın.

    4. Roller sayfasında AliyunKafkaConnectorRole öğesini bulun ve üzerine tıklayın.

    5. AliyunKafkaConnectorRole ayrıntıları sayfasında Güven İlkesi Yönetimi sekmesine tıklayın ve ardından Güven İlkesini Düzenle seçeneğine tıklayın.

    6. Güven İlkesini Düzenle panelinde betikteki fc ifadesini alikafka ile değiştirin ve ardından Tamam seçeneğine tıklayın.

      Değişiklikleri kaydettikten sonra AliyunKafkaConnectorRole üzerindeki Güven İlkesi Yönetimi sekmesinde güven ilkesindeki Service parametresinin alikafka.aliyuncs.com olarak güncellendiğini ve Action parametresinin sts:AssumeRole olarak ayarlandığını onaylayın.

    İzin ekleme

    Hedef hesapta RAM rolüne Function Compute'a erişim izni verin.

    1. Soldaki gezinme bölmesinde Kimlik Yönetimi > Roller seçeneğine gidin.

    2. Roller sayfasında AliyunKafkaConnectorRole öğesini bulun ve İşlemler sütununda İzin Ekle seçeneğine tıklayın.

    3. İzin Ekle panelinde KafkaConnectorFcAccess ilkesini ekleyin.

      1. İlke Seç bölümünde Özel İlke seçeneğini belirleyin.

      2. Yetkilendirme İlke Adı listesinde KafkaConnectorFcAccess öğesini bulun ve üzerine tıklayın.

      3. Tamam seçeneğine tıklayın.

      4. Tamamla seçeneğine tıklayın.

    Function Compute sink connector için konular oluşturma

    ApsaraMQ for Kafka konsolunda bir Function Compute sink connector için gereken beş konuyu manuel olarak oluşturabilirsiniz: görev ofset konusu, görev yapılandırması konusu, görev durumu konusu, ölü harf kuyruğu konusu ve hata verisi konusu. Bu konuların bölüm sayısı ve depolama motoru için farklı gereksinimleri vardır. Daha fazla bilgi için bkz. Kaynak Hizmeti Yapılandırma adımındaki parametreler.

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

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

      Önemli

      Konuları uygulamanızın bulunduğu bölgede, yani ECS örneğinin dağıtıldığı bölgede oluşturmanız gerekir. Konular bölgeler arasında kullanılamaz. Örneğin, bir konu Çin (Pekin) bölgesinde oluşturulursa mesaj üreticisi ve tüketicisi de Çin (Pekin) bölgesindeki bir ECS örneğinde çalışmalıdır.

    3. Instances sayfasında hedef örneğin adına tıklayın.

    4. Soldaki gezinme bölmesinde Topics seçeneğine tıklayın.

    5. Topics sayfasında Create Topic seçeneğine tıklayın.

    6. Create Topic panelinde konu ayarlarını yapılandırın ve Tamam seçeneğine tıklayın.

      Parametre

      Açıklama

      Örnek

      Name

      Konunun adı.

      Not

      Kafka, alt çizgi (xxx_xxx) ve nokta (xxx.xxx) içeren konu adlarını aynı kabul eder. Yinelenen bir konu oluşturmaya çalışırsanız sistem hata bildirir.

      demo

      Description

      Konu hakkında kısa bir açıklama.

      demo testi

      Partitions

      Konunun bölüm sayısı.

      12

      Storage Engine

      Not

      Şu anda depolama motorunu yalnızca sunucusuz olmayan Professional Edition örnekler için seçebilirsiniz. Diğer örnek türleri için bu seçenek kullanılamaz ve varsayılan olarak Bulut Depolama kullanılır.

      Konudaki mesajlar için depolama motoru.

      ApsaraMQ for Kafka aşağıdaki iki depolama motorunu destekler:

      • Cloud Storage: Bu motor, temel depolama için Alibaba Cloud disklerini kullanır ve dağıtılmış üç çoğaltma mekanizmasıyla yüksek performans, düşük gecikme süresi ve yüksek güvenilirlik sağlar. Örneğin Instance Edition Standard (High Write) ise yalnızca Cloud Storage kullanılabilir.

      • Local Storage: Bu motor, yerel Kafka eş zamanlı çoğaltma (ISR) çoğaltma algoritmasını ve dağıtılmış üç çoğaltma mekanizmasını kullanır.

      Cloud Storage

      Message Type

      Konudaki mesajların türü.

      • Normal Message: Varsayılan olarak Kafka aynı anahtara sahip mesajları aynı bölüme dağıtır ve gönderildikleri sırayla saklar. Kümedeki bir düğüm başarısız olursa mesajlar sırasız hale gelebilir. Storage Engine olarak Cloud Storage seçilirse sistem varsayılan olarak Normal Message seçeneğini belirler.

      • Partitionally Ordered Message: Varsayılan olarak Kafka aynı anahtara sahip mesajları aynı bölüme dağıtır ve gönderildikleri sırayla saklar. Küme düğümü başarısız olsa bile bölüm içi mesaj sırası garanti edilir. Ancak bazı bölümlere mesaj gönderme işlemi bu bölümler kurtarılan kadar başarısız olabilir. Storage Engine olarak Local Storage seçilirse sistem varsayılan olarak Partitionally Ordered Message seçeneğini belirler.

      Normal Message

      Log Cleanup Policy

      Konu için günlük temizleme ilkesi.

      Storage Engine olarak Local Storage seçildiğinde (şu anda yalnızca Professional Edition örnekleri yerel depolamayı destekler ve Standard Edition örneklerinde bu seçenek kullanılamaz) Log Cleanup Policy yapılandırmanız gerekir.

      ApsaraMQ for Kafka aşağıdaki iki günlük temizleme ilkesini destekler.

      • Delete: Varsayılan mesaj temizleme ilkesi. Disk alanı yeterliyse mesajlar belirtilen saklama süresi içinde tutulur. Disk alanı yetersizse (genellikle disk kullanımı %85'i aştığında) sistem hizmet kullanılabilirliğini sağlamak için eski mesajları erken siler.

      • Compact: Kafka Log Compaction temizleme ilkesini kullanır. Günlük sıkıştırma sisteminin her mesaj anahtarı için en son değeri tutmasını sağlar. Bu özellik öncelikle sistem çökmesinden sonra durumu geri yükleme veya sistem yeniden başlatıldıktan sonra önbelleği yeniden yükleme gibi senaryolar için kullanılır. Örneğin Kafka Connect ve Confluent Schema Registry sistem durumu ve yapılandırma verilerini depolamak için sıkıştırılmış konuları kullanır.

        Önemli

        Sıkıştırılmış konular genellikle yalnızca Kafka Connect veya Confluent Schema Registry gibi belirli ekosistem bileşenleri için kullanılır. Genel mesaj üretimi ve tüketimi için kullanılan konularda bu özelliği ayarlamayın. Daha fazla bilgi için ApsaraMQ for Kafka Demo Kitaplığı'na bakın.

      Compact

      Tag

      Konu için etiketler.

      demo

      Konuyu oluşturduktan sonra konu Topics sayfasındaki konu listesinde görünür.

    FC sink connector için consumer group oluşturma

    ApsaraMQ for Kafka konsolunda bir Function Compute sink connector veri senkronizasyon görevi için consumer group öğesini manuel olarak oluşturabilirsiniz. ApsaraMQ for Kafka konsolunda bir Function Compute sink connector veri senkronizasyon görevi için consumer group adı connect-görev-adı biçiminde olmalıdır. Daha fazla bilgi için bkz. Kaynak Hizmeti Yapılandırma adımındaki parametreler.

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

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

    3. Instances sayfasında hedef örneğin adına tıklayın.

    4. Soldaki gezinme bölmesinde Groups seçeneğine tıklayın.

    5. Groups sayfasında Create Group seçeneğine tıklayın.

    6. Create Group panelinde Group ID metin kutusuna consumer group için bir ad girin, Description metin kutusuna kısa bir açıklama girin, consumer group'a etiketler ekleyin ve ardından Tamam seçeneğine tıklayın.

      Oluşturulduktan sonra consumer group Groups sayfasındaki listede görünür.

    FC Sink Connector oluşturma ve dağıtma

    Verileri ApsaraMQ for Kafka kaynağından Function Compute'a senkronize etmek için bir FC Sink Connector oluşturun ve dağıtın.

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

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

    3. Soldaki gezinme bölmesinde Connectors seçeneğine tıklayın.

    4. Connectors sayfasında Select Instance açılır listesinden connector'ün ait olduğu örneği seçin ve Create Connector seçeneğine tıklayın.

    5. Create Connector sihirbazında aşağıdaki adımları tamamlayın.

      1. Configure Basic Information sekmesinde gerekli parametreleri yapılandırın ve ardından Next seçeneğine tıklayın.

        Parametre

        Açıklama

        Örnek

        Name

        Connector'ün adı. Ad aşağıdaki gereksinimleri karşılamalıdır:

        • Ad en fazla 48 karakter uzunluğunda olabilir ve yalnızca rakamlar, küçük harfler ve tire (-) içerebilir. Tire (-) ile başlayamaz.

        • Ad bir ApsaraMQ for Kafka örneği içinde benzersiz olmalıdır.

        Connector'ün veri senkronizasyon görevi connect-görev-adı adlı bir consumer group kullanır. Bu consumer group öğesini manuel olarak oluşturmazsanız sistem bunu otomatik olarak oluşturur.

        kafka-fc-sink

        Instance

        Varsayılan olarak örnek adı ve kimliği görüntülenir.

        demo alikafka_post-cn-st21p8vj****

      2. Configure Source Service sekmesinde Veri Kaynağı değerini Message Queue for Apache Kafka olarak ayarlayın, aşağıdaki parametreleri yapılandırın ve ardından Next seçeneğine tıklayın.

        Not

        Zaten bir konu ve bir consumer group oluşturduysanız manuel kaynak oluşturma seçeneğini belirleyin ve mevcut kaynaklarınızın bilgilerini girin. Aksi takdirde otomatik kaynak oluşturma seçeneğini belirleyin.

        Tablo 1. Kaynak hizmeti yapılandırma parametreleri

        Parametre

        Açıklama

        Örnek

        Data Source Topic

        Verilerin senkronize edildiği kaynak konu.

        fc-test-input

        Consumer Thread Concurrency

        Kaynak konu için eşzamanlı tüketici iş parçacığı sayısı. Varsayılan değer: 6. Geçerli değerler:

        • 1

        • 2

        • 3

        • 6

        • 12

        6

        Consumer Offset

        Tüketimin başlatılacağı ofset. Geçerli değerler:

        • Earliest Offset: Tüketimi en erken ofsetten başlat.

        • Latest Offset: Tüketimi en son ofsetten başlat.

        Earliest Offset

        VPC ID

        Veri senkronizasyon görevinin çalıştığı VPC'nin kimliği. Bu parametre Configure Runtime Environment seçeneğine tıklandığında görüntülenir. Varsayılan olarak bu, ApsaraMQ for Kafka örneğinizin VPC'sidir. Bir değer belirtmeniz gerekmez.

        vpc-bp1xpdnd3l***

        vSwitch ID

        Veri senkronizasyon görevinin çalıştığı vSwitch'in kimliği. Bu parametre Configure Runtime Environment seçeneğine tıklandığında görüntülenir. vSwitch, ApsaraMQ for Kafka örneğiyle aynı VPC'de olmalıdır. Varsayılan olarak bu, ApsaraMQ for Kafka örneğini dağıtırken belirttiğiniz vSwitch'tir.

        vsw-bp1d2jgg81***

        Failure Handling Policy

        Bir bölümden gelen bir mesajın teslimatı başarısız olduğunda ne olacağını kontrol eder. Bu parametre Configure Runtime Environment seçeneğine tıklandığında görüntülenir. Geçerli değerler:

        • Continue Subscription: Bölümden tüketmeye devam edin ve hatayı günlüğe kaydedin.

        • Stop Subscription: Bölümden tüketmeyi durdurun ve hatayı günlüğe kaydedin.

        Not

        • Günlükleri görüntüleme hakkında daha fazla bilgi için bkz. Connector işlemleri.

        • Hata kodlarına dayalı çözüm bulma hakkında daha fazla bilgi için bkz. Hata kodları.

        Continue Subscription

        Resource Creation Method

        Connector tarafından gereken konu ve consumer group öğesinin oluşturulma yöntemi. Bu parametre Configure Runtime Environment seçeneğine tıklandığında görüntülenir.

        • Auto

        • Manual

        Auto

        Connector Consumer Group

        Connector'ün veri senkronizasyon görevi tarafından kullanılan consumer group. Bu parametre Configure Runtime Environment seçeneğine tıklandığında görüntülenir. consumer group adı connect-görev-adı biçiminde olmalıdır.

        connect-kafka-fc-sink

        Task Offset Topic

        Tüketici ofsetlerini depolamak için kullanılan konu. Bu parametre Configure Runtime Environment seçeneğine tıklandığında görüntülenir.

        • Konu adı connect-offset ile başlamalıdır.

        • Bölümler: Konu için bölüm sayısı 1'den büyük olmalıdır.

        • Depolama motoru: Konu için depolama motoru Yerel Depolama olmalıdır.

        • cleanup.policy: Konu için günlük temizleme ilkesi compact olmalıdır.

        connect-offset-kafka-fc-sink

        Task Configuration Topic

        Görev yapılandırmalarını depolamak için kullanılan konu. Bu parametre Configure Runtime Environment seçeneğine tıklandığında görüntülenir.

        • Konu: Konu adının connect-config ile başlaması önerilir.

        • Bölümler: Konu için bölüm sayısı 1 olmalıdır.

        • Depolama motoru: Konu için depolama motoru Yerel Depolama olmalıdır.

        • cleanup.policy: Konu için günlük temizleme ilkesi compact olmalıdır.

        connect-config-kafka-fc-sink

        Task Status Topic

        Görev durumlarını depolamak için kullanılan konu. Bu parametre Configure Runtime Environment seçeneğine tıklandığında görüntülenir.

        • Konu: Konu adının connect-status ile başlaması önerilir.

        • Bölümler: Bölüm sayısını 6 olarak ayarlamanız önerilir.

        • Depolama motoru: Konu için depolama motoru Yerel Depolama olmalıdır.

        • cleanup.policy: Konu için günlük temizleme ilkesi compact olmalıdır.

        connect-status-kafka-fc-sink

        Dead-letter Queue Topic

        Connect framework'ünden gelen hata verilerini depolamak için kullanılan konu. Bu parametre Configure Runtime Environment seçeneğine tıklandığında görüntülenir. Konu kaynaklarını korumak için bu parametre ile Hata verisi konusu parametresi için aynı konuyu kullanabilirsiniz.

        • Konu: Konu adının connect-error ile başlaması önerilir.

        • Bölümler: Bölüm sayısını 6 olarak ayarlamanız önerilir.

        • Depolama motoru: Konu için depolama motoru Yerel Depolama veya Bulut Depolama olabilir.

        connect-error-kafka-fc-sink

        Error Data Topic

        Sink'ten gelen hata verilerini depolamak için kullanılan konu. Bu parametre Configure Runtime Environment seçeneğine tıklandığında görüntülenir. Konu kaynaklarından tasarruf etmek için bu parametre ile ölü harf kuyruğu konusu parametresi için aynı konuyu kullanabilirsiniz.

        • Konu: Konu adının connect-error ile başlaması önerilir.

        • Bölümler: Bölüm sayısını 6 olarak ayarlamanız önerilir.

        • Depolama motoru: Konu için depolama motoru Yerel Depolama veya Bulut Depolama olabilir.

        connect-error-kafka-fc-sink

      3. Configure Destination Service sekmesinde Hedef Hizmet için Function Compute seçeneğini belirleyin, Hedef Hizmet için aşağıdaki parametreleri yapılandırın ve Create seçeneğine tıklayın.

        Not

        Connector örneği Çin (Hangzhou) veya Çin (Chengdu) bölgesindeyse Hedef Hizmet olarak Function Compute seçtiğinizde AliyunServiceRoleForEventBridgeSourceKafka ve AliyunServiceRoleForEventBridgeConnectVPC hizmet bağlantılı rollerini oluşturmak için bir Hizmet Yetkilendirme iletişim kutusu görünür. Hizmet Yetkilendirme iletişim kutusunda Onayla seçeneğine tıklayın, ardından aşağıdaki parametreleri yapılandırın ve Create seçeneğine tıklayın. Hizmet bağlantılı rolleri zaten oluşturulmuşsa Hizmet Yetkilendirme iletişim kutusu görünmez.

        Parametre

        Açıklama

        Örnek

        Cross-account/Cross-region

        FC Sink Connector'ün verileri farklı bir hesaba veya bölgedeki bir Function Compute hizmetine senkronize edip etmediğini belirtir. Varsayılan değer: No. Geçerli değerler:

        • No: Aynı hesap, aynı bölge modu.

        • Yes: Çapraz hesap, çapraz bölge veya ikisi birden.

        Hayır

        Region

        Function Compute hizmetinin bölgesi. Varsayılan olarak bu, FC Sink Connector'ün bölgesidir. Verileri bölgeler arasında senkronize etmek için connector için genel erişimi etkinleştirmeniz ve ardından hedef bölgeyi seçmeniz gerekir. Daha fazla bilgi için bkz. FC Sink Connector için genel erişimi etkinleştirme.

        Önemli

        Cross-account/Cross-region değeri Yes olarak ayarlandığında Region görüntülenir.

        cn-hangzhou

        Service Endpoint

        Function Compute hizmetinin uç noktası. Uç noktayı Function Compute konsolundaki Genel Bakış sayfasının Ortak Bilgiler bölümünden alabilirsiniz.

        • Dahili uç nokta: Düşük gecikme süresi için önerilir. ApsaraMQ for Kafka örneğiniz ve Function Compute hizmetiniz aynı bölgedeyse bu uç nokta türünü kullanın.

        • Genel uç nokta: Daha yüksek gecikme süresi nedeniyle önerilmez. ApsaraMQ for Kafka örneğiniz ve Function Compute hizmetiniz farklı bölgelerdeyse bu uç nokta türünü kullanın. Genel uç nokta kullanmak için connector için genel erişimi etkinleştirmeniz gerekir. Daha fazla bilgi için bkz. FC Sink Connector için genel erişimi etkinleştirme.

        Önemli

        Cross-account/Cross-region değeri Yes olarak ayarlandığında Service Endpoint görüntülenir.

        http://188***.cn-hangzhou.fc.aliyuncs.com

        Alibaba Cloud Account

        Function Compute hizmetinin ait olduğu Alibaba Cloud hesabının kimliği. Kimliği Function Compute konsolundaki Genel Bakış sayfasının Ortak Bilgiler bölümünden alabilirsiniz.

        Önemli

        Cross-account/Cross-region değeri Yes olarak ayarlandığında Alibaba Cloud Account görüntülenir.

        188***

        RAM Role Name

        ApsaraMQ for Kafka'nın Function Compute hizmetine erişmek için üstlendiği RAM rolü adı.

        Önemli

        Cross-account/Cross-region değeri Yes olarak ayarlandığında RAM Role Name görüntülenir.

        AliyunKafkaConnectorRole

        Service Name

        Function Compute'deki hizmetin adı.

        guide-hello_world

        Function Name

        Function Compute hizmetindeki işlevin adı.

        hello_world

        Version or Alias

        Function Compute hizmetinin sürümü veya takma adı.

        Önemli

        • Cross-account/Cross-region değeri No olarak ayarlandığında Specified Version veya Specified Alias seçeneğini belirlemeniz gerekir.

        • Cross-account/Cross-region değeri Yes olarak ayarlandığında bir hizmet sürümü veya takma adı manuel olarak girmeniz gerekir.

        LATEST

        Service Version

        Function Compute hizmetinin sürümü.

        Önemli

        Cross-account/Cross-region değeri No ve Version or Alias değeri Specified Version olarak ayarlandığında Service Version parametresi görüntülenir.

        LATEST

        Service Alias

        Function Compute hizmetinin takma adı.

        Önemli

        Cross-account/Cross-region değeri No ve Version or Alias değeri Specified Alias olarak ayarlandığında Service Alias parametresi görüntülenir.

        jy

        Transmission Mode

        Mesajların gönderilme modu. Geçerli değerler:

        • Asynchronous: Önerilir.

        • Synchronous: Önerilmez. Bu modda Function Compute tarafından yavaş mesaj işleme ApsaraMQ for Kafka hizmetini de yavaşlatır. Bir mesaj partisinin işlenmesi 5 dakikadan fazla sürerse ApsaraMQ for Kafka hizmetinde istemci yeniden dengeleme tetiklenir.

        Asynchronous

        Data Size

        Tek bir partide yer alacak maksimum mesaj sayısı. Connector, mesajları bu sayıya ve temel istek boyutu sınırlarına (eşzamanlı için 6 MB, eşzamansız için 128 KB) uygun partiler halinde toplar. Örneğin, teslimat modu eşzamansızsa, parti boyutu 20 ise ve toplam boyutu 127 KB olan 17 mesaj ile boyutu 200 KB olan bir mesaj içeren 18 mesaj göndermek istiyorsanız connector 17 mesajı tek bir partide toplar ve gönderir. Boyutu 128 KB'yi aşan kalan mesajı ayrı bir partide gönderir.

        Not

        Bir mesaj gönderirken anahtar değerini null olarak ayarlarsanız istek anahtar içermez. değer değerini null olarak ayarlarsanız istek değer içermez.

        • Bir partideki mesajların toplam boyutu istek boyutu sınırını aşmazsa istek mesaj içeriğini içerir. Aşağıdaki kod örnek bir istek sağlar:

          [
    {
        "key":"this is the message's key2",
        "offset":8,
        "overflowFlag":false,
        "partition":4,
        "timestamp":1603785325438,
        "topic":"Test",
        "value":"this is the message's value2",
        "valueSize":28
    },
    {
        "key":"this is the message's key9",
        "offset":9,
        "overflowFlag":false,
        "partition":4,
        "timestamp":1603785325440,
        "topic":"Test",
        "value":"this is the message's value9",
        "valueSize":28
    },
    {
        "key":"this is the message's key12",
        "offset":10,
        "overflowFlag":false,
        "partition":4,
        "timestamp":1603785325442,
        "topic":"Test",
        "value":"this is the message's value12",
        "valueSize":29
    },
    {
        "key":"this is the message's key38",
        "offset":11,
        "overflowFlag":false,
        "partition":4,
        "timestamp":1603785325464,
        "topic":"Test",
        "value":"this is the message's value38",
        "valueSize":29
    }
]

        • Tek bir mesajın boyutu istek boyutu sınırını aşarsa istek mesaj içeriğini içermez. Aşağıdaki kod örnek bir istek sağlar:

          [
    {
        "key":"123",
        "offset":4,
        "overflowFlag":true,
        "partition":0,
        "timestamp":1603779578478,
        "topic":"Test",
        "value":"1",
        "valueSize":272687
    }
]
          Not

          Mesaj içeriğini almak için mesajı ofsetine göre çekmeniz gerekir.

        50

        Retries

        Bir mesaj gönderilemediğinde yapılan yeniden deneme sayısı. Varsayılan değer 2'dir. Değer aralığı 1 ile 3 arasındadır. Mesaj gönderiminin başarısız olmasına neden olan bazı hatalar yeniden denemeyi desteklemez. Hata kodları ile yeniden deneme desteği arasındaki eşleme aşağıdaki gibidir:

        • 4XX: 429 dışındaki tüm 4xx hataları için yeniden deneme desteklenmez.

        • 5XX: Yeniden deneme desteklenir.

        Not

        • Connector, mesajları Function Compute'a göndermek için InvokeFunction işlemini çağırır.

        • Bir mesaj maksimum yeniden deneme sayısından sonra gönderilemezse ölü harf kuyruğu konusuna gönderilir. Ölü harf kuyruğu konusundaki mesajlar Function Compute connector görevlerini tekrar tetiklemez. Durumunu gerçek zamanlı olarak izlemek ve özel durumları zamanında işlemek için ölü harf kuyruğu konusu için uyarılar yapılandırmanızı öneririz.

        2

        Connector oluşturulduktan sonra Connectors sayfasında görüntüleyebilirsiniz.

    6. Connectors sayfasında yeni oluşturduğunuz connector'ü bulun ve Actions sütununda Deploy seçeneğine tıklayın.

      Function Compute kaynaklarını yapılandırmak için Actions sütununda More > Configure Function seçeneğini belirleyin. Yapılandırmayı tamamlamak üzere Function Compute konsoluna yönlendirilirsiniz.

    Test mesajı gönderme

    Function Compute sink connector'ü dağıttıktan sonra ApsaraMQ for Kafka örneğinizdeki kaynak konuya bir mesaj göndererek verilerin Function Compute'a senkronize edildiğini doğrulayabilirsiniz.

    1. Connectors sayfasında hedef connector'ü bulun ve Actions sütununda Test seçeneğine tıklayın.

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

      • Sending Method için Console seçeneğini belirleyin.

        1. Message Key alanında demo gibi bir mesaj anahtarı girin.

        2. Message Content alanında {"key": "test"} gibi mesaj içeriğini girin.

        3. Send to Specified Partition için bir seçenek belirleyin:

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

          • No seçeneğine tıklayarak mesajı bir bölüm belirtmeden gönderin.

      • Sending Method için Docker seçeneğini belirleyin ve Run the Docker container to produce a sample message bölümündeki komutu çalıştırın.

      • Sending Method için SDK seçeneğini belirleyin. Ardından tercih ettiğiniz dil veya çerçeve için SDK ve entegrasyon yöntemini seçerek bir mesaj gönderin.

    İşlev günlükleri

    ApsaraMQ for Kafka örneğinizdeki kaynak konuya bir mesaj gönderdikten sonra işlevin mesajı aldığını doğrulamak için işlev günlüklerini kontrol edin. Daha fazla bilgi için bkz. Günlükleri yapılandırma.

    Test mesajınız günlüklerde görünür.

    İşlev ayrıntıları sayfasında Günlük sorgusu sekmesine tıklayın ve Gelişmiş sorgu seçeneğini belirleyin. Logstore olarak function-log seçeneğini belirleyin. Günlüklerdeki message alanı Kafka konusundaki mesajı içerir; örneğin [INFO] hello world:[{"key":"1","offset":1,"partition":0,"timestamp":1605598174308,"topic":"fc-test-input","value":"1"}]. Bu, işlevin Kafka tetikleyicisinden mesajı başarıyla aldığını onaylar.