Tüm Ürünler
Search

Bu Ürün

    ApsaraMQ for Kafka:CloudMonitor (V2 ayrılmış örnekler)

    Belge Merkezi

    ApsaraMQ for Kafka:CloudMonitor (V2 ayrılmış örnekler)

    Son Güncelleme:Oct 13, 2026

    ApsaraMQ for Kafka kaynaklarını (örnekler, konular ve tüketici grupları) gerçek zamanlı olarak izlemek ve ölçümler eşikleri aştığında uyarı almak için CloudMonitor'u kullanın.

    Ölçümler

    Not

    • Ölçüm verileri 1 dakikalık bir süre boyunca toplanır. Saniye başına bayt (B/s) gibi saniye başına bildirilen bir değer, önceki dakikanın ortalamasını temsil eder.

    • Ölçüm verilerinin gecikme süresi 1 dakikadır.

    • Bu ölçümler CloudMonitor ad alanı acs_kafka (ProductCategory: kafka) içinde yer alır. Ölçümleri CloudMonitor API veya SDK kullanarak sorgulamak için bu tanımlayıcılara ihtiyacınız vardır.

    • Ölçüm kimliğinde V2 son eki bulunan ölçümler (örneğin InstanceCpuUsageV2), yalnızca V2 ayrılmış örnekler için geçerlidir.

    • Tüketimle ilgili ölçümler ofset commit işlemlerine bağlıdır. Tüketilmemiş mesaj sayısı gibi ölçümler, istemci tarafından commit edilen tüketici ofsetine göre hesaplanır. İstemci ofsetleri düzgün bir şekilde commit etmezse (örneğin, otomatik commit etkinleştirilmezse veya manuel commit yapılandırılmazsa), izleme verileri gerçek tüketim durumunu doğru yansıtamaz ve bu durum yanlış uyarılara neden olabilir. İstemcinizin bir ofset commit mekanizması ile doğru şekilde yapılandırıldığından emin olun.

    • Sunucu tarafında kısıtlama olup olmadığını belirlemek için Instance Produce Throttle Queue Size (InstanceProduceThrottleQueueSizeV2) veya Instance Consume Throttle Queue Size (InstanceFetchThrottleQueueSizeV2) ölçümünü izleyin. Kısıtlamanın gerçekleştiği ancak bu ölçüm sıfırdan farklı değerler raporladığında kabul edilir. Küçük trafik aşımı durumlarında genellikle esnek bir arabellek bulunur ve kısıtlama hemen tetiklenmez.

    • Production Traffic Ratio (InstanceMessageInputRatioV2) ve Consumption Traffic Ratio (InstanceMessageOutputRatioV2) düğüm düzeyindeki trafik kullanımını yansıtır. Kafka varsayılan olarak 3 çoğaltma ile çalıştığından ve aktarım hızı kapasitesi eşit dağıtıldığından, tek bir düğümdeki saniyelik trafik örneğin periyodik toplu gönderilerin neden olduğu ani trafik artışları nedeniyle anlık olarak limiti aşabilir; bu durum örnek ortalama hızının yapılandırılan eşiğe ulaşmamasına rağmen gerçekleşebilir. İzleme grafikleri dakika düzeyinde yumuşatılmış verileri gösterirken, gerçek kısıtlama saniye düzeyindeki izlemeye göre tetiklenir. Trafik artışları sırasında bu iki değer arasında önemli farklar olabilir.

    ApsaraMQ for Kafka aşağıdaki ölçümleri destekler:

    Not

    Yaygın izleme senaryoları için aşağıdaki ölçümlerle başlayın:

    • Depolama uyarıları: instance_disk_capacity (disk kullanım yüzdesi) ölçümünü izleyin ve uyarı eşiğini %85 olarak ayarlayın.

    • Tüketici gecikmesi tespiti: Yavaş veya takılı kalan tüketicileri tespit etmek için message_accumulation (tüketici grubu mesaj birikimi) ölçümünü izleyin.

    • Kapasite planlaması: Örnek yükseltmelerini planlamak için InstanceMessageInputRatioV2 (gelen trafiğin örnek teknik özelliklerine oranı) ve PartitionInstanceRatioV2 (bölüm sayısının örnek teknik özelliklerine oranı) ölçümlerini izleyin.

    Örnek düzeyindeki ölçümler


    Ölçüm adı


    Ölçüm Kimliği


    Boyutlar


    Birim


    Örnek disk kullanımı


    instance_disk_capacity


    instanceId


    %


    Örnek genel gelen bant genişliği


    instance_internet_rx.rate


    instanceId


    bit/s


    Örnek genel giden bant genişliği


    instance_internet_tx.rate


    instanceId


    bit/s


    Örnek gelen trafik


    instance_message_input


    instanceId


    B/s


    Örneğe üretilen mesajlar


    instance_message_num_input


    instanceId


    count/s


    Örnek giden trafik


    instance_message_output


    instanceId


    B/s


    Örneğe yapılan mesaj gönderme istekleri


    instance_reqs_input


    instanceId


    count/s


    Örnektaki mesaj tüketim istekleri


    instance_reqs_output


    instanceId


    count/s


    Örnek toplu iş boyutu TP50 (50. yüzdelik dilim)


    InstanceBatchSizeTP50V2


    instanceId


    Bytes


    Örnek toplu iş boyutu TP999 (99,9. yüzdelik dilim)


    InstanceBatchSizeTP999V2


    instanceId


    Bytes


    Örnek CPU kullanımı


    InstanceCpuUsageV2


    instanceId


    %


    Örnek getirme kısıtlama kuyruğu boyutu


    InstanceFetchThrottleQueueSizeV2


    instanceId


    count


    Örnek yüksek kullanılabilirlik (HA) olayları


    InstanceHAEventV2


    instanceId


    count


    Örnek genel gelen bant genişliği (düğüm başına)


    InstanceInternetRxRateByNode


    instanceId, nodeIp


    bit/s


    Örnek genel gelen bant genişliği kullanımı (düğüm başına)


    InstanceInternetRxUtilizationByNode


    instanceId, nodeIp


    %


    Örnek genel giden bant genişliği (düğüm başına)


    InstanceInternetTxRateByNode


    instanceId, nodeIp


    bit/s


    Örnek genel giden bant genişliği kullanımı (düğüm başına)


    InstanceInternetTxUtilizationByNode


    instanceId, nodeIp


    %


    Örnek maksimum bağlantı sayısı


    InstanceMaxConnection


    instanceId


    count


    Örnek maksimum Internet bağlantısı sayısı


    InstanceMaxInternetConnection


    instanceId


    count


    Örnek maksimum okuma IOPS (saniye başına giriş/çıkış işlemi)


    InstanceMaxReadIOPSV2


    instanceId


    count/s


    Örnek maksimum yazma IOPS


    InstanceMaxWriteIOPSV2


    instanceId


    count/s


    Gelen trafiğin örnek teknik özelliklerine oranı


    InstanceMessageInputRatioV2


    instanceId


    %


    Giden trafiğin örnek teknik özelliklerine oranı


    InstanceMessageOutputRatioV2


    instanceId


    %


    Örnek üretim kısıtlama kuyruğu boyutu


    InstanceProduceThrottleQueueSizeV2


    instanceId


    count


    Örnek yeniden dengeleme süresi


    InstanceRebalanceTimeV2


    instanceId


    ms


    Örnek toplam bağlantı sayısı


    InstanceTotalConnection


    instanceId


    count


    Örnek toplam Internet bağlantısı sayısı


    InstanceTotalInternetConnection


    instanceId


    count


    Bölüm sayısının örnek teknik özelliklerine oranı


    PartitionInstanceRatioV2


    instanceId


    %

    Tüketici grubu düzeyindeki ölçümler


    Ölçüm adı


    Ölçüm Kimliği


    Boyutlar


    Birim


    Tüketici grubu mesaj çıktısı


    group_message_num_output


    instanceId, consumerGroup


    count/s


    Bir konu için tüketici grubu mesaj çıktısı


    group_message_num_output_onetopic


    instanceId, consumerGroup, topic


    count/s


    Tüketici grubu tüketim gecikme süresi


    group_topic_accumulation_consume_cost_time


    instanceId, consumerGroup


    ms


    Tüketici grubu mesaj birikimi


    message_accumulation


    instanceId, consumerGroup


    count


    Bir konu için tüketici grubu mesaj birikimi


    message_accumulation_onetopic


    instanceId, consumerGroup, topic


    count

    Konu düzeyindeki ölçümler


    Ölçüm adı


    Ölçüm Kimliği


    Boyutlar


    Birim


    Konu gelen trafiği


    topic_message_input


    instanceId, topic


    B/s


    Bir konuya üretilen mesajlar


    topic_message_num_input


    instanceId, topic


    count/s


    Konu giden trafiği


    topic_message_output


    instanceId, topic


    B/s


    Konu tüketim-üretim trafik oranı


    topic_message_output_input_ratio


    instanceId, topic


    %


    Konu mesaj gönderme istekleri


    topic_reqs_input


    instanceId, topic


    count/s


    Konu mesaj tüketim istekleri


    topic_reqs_output


    instanceId, topic


    count/s

    Faturalama

    ApsaraMQ for Kafka için CloudMonitor özelliği ücretsizdir.

    Önkoşullar

    Bir hizmet bağlantılı rol gereklidir.

    • Rol adı: AliyunServiceRoleForAlikafka

    • İlke adı: AliyunServiceRolePolicyForAlikafka

    • İzinler: ApsaraMQ for Kafka hizmetine, izlemeyle ilgili özellikler için CloudMonitor ve Application Real-Time Monitoring Service (ARMS) gibi diğer hizmetlerinize erişim izni verir.

    • Daha fazla bilgi için bkz. Hizmet bağlantılı roller.

    İzleme verilerini görüntüleme

    1. ApsaraMQ for Kafka konsolu üzerinde 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. Sol gezinme bölmesinde, Observability > CloudMonitor seçeneğini belirleyin.

    5. CloudMonitor sayfasında, Alert Rule sekmesine tıklayın. İzlemek istediğiniz kaynağın sekmesini seçin, kaynağı bulun ve ardından Actions sütunundaki View CloudMonitor Metrics seçeneğine tıklayın. İzleme verilerini görüntülemek için bir zaman aralığı ayarlayın.

      Geçerli kaynağın tüm ölçümlerine ait grafikler otomatik olarak görünür.

    Uyarı kuralı ayarlama

    1. CloudMonitor sayfasında, Alert Rule sekmesine tıklayın ve ardından Instance, Topic veya Group sekmesini seçin.

      Bu işlem, sizi CloudMonitor konsolundaki Create Alert Rule paneline yönlendirir.

    2. Create Alert Rule panelinde kuralı ve bildirim bilgilerini yapılandırın ve ardından OK seçeneğine tıklayın. Parametreler hakkında daha fazla bilgi için bkz. Uyarı kuralı oluşturma.

    3. OK seçeneğine tıkladıktan sonra, uyarı kuralı Alert Rule sekmesinde görünür. Kural durumunun Enabled olduğunu doğrulayın.

    Örnek: DingTalk robot bildirimi ile Grup mesaj birikimi uyarısı yapılandırma

    Not

    Uyarıyı yapılandırmadan önce, Cloud Monitor konsolunda oturum açın ve bir DingTalk robotunu uyarı kişisi veya kişi grubu olarak ekleyin. DingTalk robotunun Webhook URL'si önceden kaydedilmiş olmalıdır.

    1. ApsaraMQ for Kafka konsolu üzerinde oturum açın.

    2. Sol gezinme bölmesinde, Observability > CloudMonitor seçeneğini belirleyin.

    3. Alert Rule sekmesine tıklayın.

    4. Group kaynak sekmesine tıklayın.

    5. Uyarı yapılandırmak istediğiniz Grubu bulun ve Actions sütunundaki Create Alert Rule seçeneğine tıklayın. Sayfa, Cloud Monitor konsolundaki Create Alert Rule paneline yönlendirilir.

    6. Create Alert Rule panelinde aşağıdaki ayarları yapılandırın:

      • Metric: Mesaj birikimi ölçümü MessageAccumulationV3 (Group Message Backlog Total) seçin.

      • Alert conditions: Eşik değerini ve uyarı gönderilmeden önce koşulun tetiklenmesi gereken ardışık dönem sayısını ayarlayın.

      • Notification method: Bildirim kişileri altında, önkoşul olarak yapılandırdığınız DingTalk robot kişi grubunu seçin.

    7. Uyarı kuralını kaydetmek için OK seçeneğine tıklayın.

    Kural oluşturulduktan sonra, Alert Rule sekmesi durumu Enabled olarak ayarlanmış yeni kuralı gösterir. Grup mesaj birikimi yapılandırılan eşiği aştığında, Cloud Monitor belirtilen DingTalk robotuna bir bildirim gönderir.

    Uyarı bilgilerini görüntüleme

    1. CloudMonitor sayfasında, Alert Rule sekmesine tıklayın. Ardından, uyarı bilgilerini görüntülemek istediğiniz kaynağın sekmesini seçin; örneğin Instance, Topic veya Group.

    2. Kaynağı bulun ve Actions sütunundaki Alert Rule seçeneğine tıklayın.

    3. Associated Alert Rules panelinde, hedef uyarı kuralını bulun ve kural yapılandırmasını ile uyarı geçmişini görüntülemek için Actions sütunundaki Details seçeneğine tıklayın. Bu sayfadan kuralı etkinleştirebilir, devre dışı bırakabilir veya silebilirsiniz.

    SSS

    Cloud Monitor CPU, bellek ve günlük yazma hacmi istatistiklerini destekler mi?

    • CPU ve bellek izleme: ApsaraMQ for Kafka, CPU ve bellek izleme ölçümlerini Cloud Monitor aracılığıyla doğrudan sunmaz. Sistem kaynak kullanımını izlemek için Prometheus izleme konusunda açıklanan Prometheus izleme çözümüne bakın.

    • Günlük yazma hacmi: Cloud Monitor özel bir günlük yazma hacmi görünümü sağlamaz. Günlük yazma hacmini aşağıdaki yöntemleri kullanarak tahmin edebilirsiniz:

      • Konsol: Örnek ayrıntıları sayfasında, Topic Management bölümüne gidin ve hedef konu için izleme bilgilerindeki yazma aktarım hızını (B/s) görüntüleyin. Alternatif olarak, Cloud Monitor sayfasında Instance Actual Inbound Traffic (instance_message_input, birim: B/s) veya Instance Message Production Count (instance_message_num_input, birim: count/s) ölçümünü görüntüleyin ve günlük hacmi tahmin etmek için bunu bir gündeki saniye sayısı ile çarpın.

      • Prometheus izleme: Sürekli gelen trafik verilerini elde etmek için instance_message_input (bayt/s) ve instance_message_num_input (mesaj/s) örnek düzeyindeki ölçümleri sorgulayın.

      • API sorgusu: Belirli bir zaman aralığında üretilen kesin mesaj sayısını hesaplamak için QueryMessage API'sini kullanarak zaman damgasına göre ofset farklarını sorgulayın.

    Referanslar

    Not

    Ölçümler görüntülenmiyorsa, AliyunServiceRoleForAlikafka hizmet bağlantılı rolünün oluşturulduğunu ve örneğin çalıştığını doğrulayın.