Değişiklik olay akışı için AMQP protokolünün kullanımdan kaldırılması

Bu makale, SQL Server 2025, Azure SQL Veritabanı, Azure SQL Yönetilen Örneği ve Microsoft Fabric'teki SQL veritabanı için AMQP protokolünün değişim olay akışı (CES) özelliğinin kullanımdan kaldırılmasını açıklamaktadır.

AMQP protokolünün kullanımdan kaldırılması, yeni akış grupları oluşturulurken yapılandırma destination_type değerinde kırıcı bir değişiklik getirir. Dağıtım programı ürüne göre değişir. Bu makale, bu değişikliklerin yeni ve mevcut akış gruplarını nasıl etkilediğini, platforma özgü farklılıkları ve mevcut akış gruplarının AMQP protokolünden Kafka protokolüne nasıl taşınacağını açıklar.

AMQP protokolü nedir?

AMQP protokolü ("AMQP"), CES'in Azure Event Hubs ve Fabric Eventstream'e değişiklik olayları gönderirken desteklediği iki protokolden biriydi. Bu, Azure Event Hubs ve Fabric Eventstream'e olaylar yayımlayan bir servis-hizmet uygulamasıydı.

Bu bozucu değişiklikten önce, bir akış destination_type değerinde aşağıdaki desteklenen değerlerden birini kullanarak yapılandırma değerinde protokolü belirlemiştiniz:

  • AzureEventHubsAMQP - AMQP protokolü
  • AzureEventHubsApacheKafka - Kafka protokolü

Bu bozucu değişiklikten sonra, Azure SQL Veritabanı ve SQL veritabanı Microsoft Fabric'te yeni oluşturulan akış grupları için desteklenen destination_type tek değer, AzureEventHubsKafka protokolünü kullanan 'dir. Azure SQL Yönetilen Örneği ve SQL Server 2025 hâlâ AzureEventHubsAMQP kabul ediyor ve AzureEventHubsApacheKafka.

15 Ağustos 2026 itibarıyla, Azure SQL Veritabanı'de AzureEventHubsyeni oluşturulan akış grupları .destination_type Önceki değerler kullanılarak bir akış grubu oluşturma girişimleri başarısız olur.

Azure Event Hubs'a yayınlanan mesajların tüketicileri, mesajı yayımlayan protokol ne olursa olsun AMQP veya Kafka protokolü arasında seçim yapabilir.

destination_type değerleri için platform desteği

Yeni bir akış grubu oluşturulduğunda izin verilen destination_type değerler ürün ve sürüme bağlıdır:

Ürün İzin verilen destination_type değerler Notlar
Azure SQL Veritabanı AzureEventHubs Desteklenen tek değer. AzureEventHubsAMQP ve AzureEventHubsApacheKafka yeni akış grupları için kabul edilmiyorlar.
Azure SQL Yönetilen Örneği AzureEventHubsAMQP, AzureEventHubsApacheKafka Bu değerler hâlâ kabul edilir ancak kullanımdan geçerli. Yeni akış grupları için kaçının AzureEventHubsAMQP .
SQL Server 2025 AzureEventHubsAMQP, AzureEventHubsApacheKafka Bu değerler hâlâ kabul edilir ancak kullanımdan geçerli. Yeni akış grupları için kaçının AzureEventHubsAMQP .
Microsoft Fabric'te SQL veritabanı AzureEventHubs Desteklenen tek değer.

Yeni akış grupları için, platform desteklediğinde kullanın AzureEventHubs . Azure SQL Yönetilen Örneği ve SQL Server 2025 için AzureEventHubsApacheKafka use (Kafka protocol). Yeni akış grupları için kaçının AzureEventHubsAMQP .

AMQP ile yapılandırılmış akış gruplarını Kafka'ya nasıl aktarılır

Mevcut CES grupları ile AzureEventHubsAMQP yapılandırılmış olanlar, AMQP protokolü kullanarak mesajları Nisan 2027'ye kadar yayınlamaya devam etmektedir. SQL Server 2025, Azure SQL Veritabanı, Azure SQL Yönetilen Örneği veya Microsoft Fabric'te SQL veritabanı içinde mevcut AMQP ile yapılandırılmış akış gruplarınızı mümkün olan en kısa sürede yeniden AzureEventHubsdestination_type oluşturun.

Tüm yapılandırılmış akış gruplarını tanımlamak için aşağıdaki sorguyu kullanın:

exec sp_help_change_event_stream_groups

AzureEventHubsAMQP sütununda bulunan akış grupları için yapılandırma değerlerini kaydet. Yeni akış gruplarını oluştururken bu değerlere ihtiyacınız var.

Her akış grubundaki ve geçiş yapmanız gereken tabloları belirlemek için aşağıdaki sorguyu kullanın:

exec sys.sp_help_change_event_stream_tables

AMQP ile yapılandırılmış bir akış grubunu Kafka'ya taşımak için şu adımları izleyin:

  1. sys.sp_create_event_stream_group depolanmış prosedürü kullanarak bir yedek akış oluşturun. Parametre olarak AzureEventHubs belirtdestination_type.

    Parametre, destination_location aşağıdaki örnek gibi 9093 portunu bekliyor: myEventHubsNamespace.servicebus.windows.net:9093/myEventHubsInstance.

    Kafka protokolü, Microsoft Entra veya servis anahtarı kimlik doğrulamasını destekler. SAS kimlik doğrulaması artık CES için kullanılamaz.

  2. Her tabloyu eski akış grubundan teker teker çıkararak sys.sp_remove_object_from_event_stream_group:

    exec sys.sp_remove_object_from_event_stream_group @stream_group_name = '<old_stream_group_name>', @object_name = '<schema.table_name>'

  3. Eski akış grubundan çıkardığınız her tabloyu yeni yedek akış grubuna ekleyin sys.sp_add_object_to_event_stream_group:

    exec sys.sp_add_object_to_event_stream_group @stream_group_name = '<new_stream_group_name>', @object_name = '<schema.table_name>'

  4. Tüm tabloları yeni akış grubuna ekledikten sonra, eski akış grubunu kaldırmak için sys.sp_drop_event_stream_group kullanın. Detaylar için configure CES'i inceleyin.

    exec sys.sp_drop_event_stream_group @stream_group_name = '<old_stream_group_name>'

  5. Yeni akış grubunun aktif olduğunu çalıştırıp sp_help_change_event_stream_groupsAzureEventHubs olarak göründüğünü doğrulayarak doğrulayın.

Bu süreci ortamınızdaki her AMQP ile yapılandırılmış akış grubu için tekrarlayın.

Tabloları yeni akış gruplarına taşıma (Kafka)

CES, değişiklikleri oluşturulduğu anda günlük dosyasından tarar ve yayımlar, ancak yayınlama gecikmesi olayların gecikmesine neden olabilir. Bir akış grubundan bir tabloyu kaldırdığınızda, log dosyasında bekleyen değişiklikler yayınlanmıyor. Bu nedenle, akış grupları arasında tabloları dikkatlice koordine edin ki olayları kaçırın.

Bir akış grubundan bir tabloyu kaldırmadan önce, tablolarda yayınlanacak bekleyen değişiklikler olmadığından emin olmak için sys.dm_change_feed_log_scan_sessions DMV'yi kontrol edin. Bekleyen değişiklikler varsa, eski akış grubundan tabloyu çıkarıp yeni akış grubuna eklemeden önce sürecin yayınlamasını bekleyin.

Kaçırılmış etkinliklerin riskini azaltmak için aşağıdaki yaklaşımlardan birini kullanın:

  • Tablolara yazma yapılmadığında, özel bir bakım penceresinde akış grupları arasında tabloları taşın.
  • Düşük aktivite döneminde yayınlanan tablolara özel bir kilitleme uygulayarak yeni yazıların önlenmesini sağlar. Özel kilidi sadece tablolar yeni akış grubuna girdikten sonra serbest bırakın.

Kullanımdan kaldırılma zaman çizelgeleri

AMQP protokolünün kullanımdan kaldırılması şu iki zaman çizelgesini takip eder:

Akarsu grubu tipi Geçerlilik tarihi Etki
Azure SQL Veritabanı ve SQL database in Microsoft Fabric üzerinde yeni akış grupları 15 Ağustos 2026 Yeni oluşturulan akış grupları AzureEventHubs olarak belirtilmelidir.destination_type İkisini AzureEventHubsAMQP kullanmaya çalışmak ya da AzureEventHubsApacheKafka başarısız olmak.
New stream groups on Azure SQL Yönetilen Örneği and SQL Server 2025 Gelecek güncelleme (Belirlenecek) AzureEventHubsAMQP ve AzureEventHubsApacheKafka hâlâ kabul ediliyor ama kullanımdan dolayı geçerli. Gelecekteki bir güncelleme gerekli değer olarak eklenecek AzureEventHubs .
AMQP protokolünü kullanan mevcut akış grupları Nisan 2027 Zaten yapılandırılmış AzureEventHubsAMQP akış grupları bu tarihe kadar normal çalışmaya devam ediyor. AMQP protokolü desteği kaldırılmadan önce Kafka protokolünü kullanmak üzere taşınmalıdırlar.

Yayınlanan mesajların tüketicilerinin herhangi bir değişiklik yapmasına gerek yoktur.

Kullanımdan kaldırılma etkisi

Bu bölüm, AMQP protokolünün kullanımdan kaldırılmasının etkisini açıklar, örneğin:

Yayınlanan mesajların tüketicileri üzerindeki etkisi

Hedef noktaya (Azure Event Hubs veya Fabric Eventstream) yazmak için kullanılan protokol, mesaj tüketicilerinin kullandığı protokolden bağımsızdır. Bu nedenle, mesaj yayınlama için AMQP'den Kafka protokolüne geçmek mesaj tüketicilerini etkilemez. Her iki protokolü kullanarak mesaj tüketmeye devam edebilirler.

Mevcut AMQP akış grupları üzerindeki etkisi

Mevcut akış grupları AMQP AzureEventHubsAMQP protokolünü kullanarak as-isçalışmaya devam eder. Bu gruplar için anında kesinti veya yapılandırma değişikliği gerekmiyor. Ancak, AMQP protokolü desteğinin Nisan 2027'de kaldırılmasından önce AMQP ile yapılandırılmış akış gruplarını Kafka protokolünü kullanmak için taşımak zorundasınız.

Yeni oluşturulan akarsu grupları üzerindeki etkisi

15 Ağustos 2026'dan itibaren, Azure SQL Veritabanı ve SQL veritabanı Microsoft Fabric'te AzureEventHubsyeni oluşturulan akış grupları için izin verilen tek destination_type değer . Önceki değer AzureEventHubsAMQP veya AzureEventHubsApacheKafka, kullanılarak bir akış grubu oluşturma girişimleri aşağıdaki hata mesajıyla başarısız olur:

Msg 23626, Level 16, State 2, Line 481, An error occurred. The error/state returned was 23618/5: 'The value provided for the argument '@destination_type' is invalid. Allowed values: AzureEventHubs.'

Bu tarihten önce akış grupları oluşturan otomasyon betiklerini güncelleyin. Parametre destination_type yerine AzureEventHubs veya AzureEventHubsAMQPkullanmalıdırAzureEventHubsApacheKafka.

Kafka protokolü, Azure Event Hubs veya Fabric Eventstream'e bağlanmak için Microsoft Entra veya servis anahtarı kimlik doğrulaması kullanır. Mevcut AMQP akış gruplarınız SAS kimlik doğrulaması kullanıyorsa, yeni akış grupları oluştururken Microsoft Entra veya servis anahtarı doğrulamasına geçmeniz gerekir. Akış grupları için kimlik doğrulama yapılandırması hakkında detaylar için Değişiklik Olay akışını Yapılandırma bölümüne bakınız.

Yayıncı ağı yapılandırması üzerindeki etkisi

Yayınlama tarafında ağı nasıl yapılandırdığınıza bağlı olarak, izin verilen çıkış portlarını AMQP'nin kullandığı 5671 ve 5672 portları yerine Kafka'nın 9093 portunu kullanacak şekilde yeniden yapılandırmanız gerekebilir. Yayıncı, port 9093'te giden trafiğe izin vermek zorundadır.

Sadece AMQP protokolünü kullanan mevcut akış gruplarınız varsa 5671 ve 5672 portlarını açık bırakın. Bu portlar, Kafka protokolünü kullanan yeni oluşturulan akış grupları için gerekli değildir.

Daha fazla bilgi için Azure Event Hubs firewall configuration per protocol sayfasına bakınız.

İlgili içerik

  • Last updated on