Apache Kafka ekosistemleri için Azure Event Hubs'a geçiş yapma

Makale
04/11/2023

Azure Event Hubs, Kafka protokolünü kullanarak Event Hubs'a bağlanmanızı sağlayan bir Apache Kafka uç noktasını kullanıma sunar. Mevcut Kafka uygulamanızda çok az değişiklik yaparak, Azure Event Hubs’a bağlanıp Azure ekosisteminin avantajlarından faydalanabilirsiniz. Event Hubs, MirrorMaker dahil olmak üzere mevcut Kafka uygulamalarınızın birçoğu ile çalışır. Daha fazla bilgi için bkz . Apache Kafka için Event Hubs

Geçiş öncesi

Azure hesabı oluşturma

Azure aboneliğiniz yoksa başlamadan önce ücretsiz bir hesap oluşturun.

Event Hubs ad alanı oluşturma

Event Hubs ad alanı ve olay hub'ı oluşturmak için Olay hub'ı oluşturma makalesindeki adım adım yönergeleri izleyin.

Bağlantı dizesi

Portaldan bağlantı dizesini alma makalesindeki adımları izleyin. Bağlantı dizesini daha sonra kullanmak üzere not edin.

Tam etki alanı adı (FQDN)

Olay Hub'ı ad alanınızı işaret eden FQDN'ye de ihtiyacınız olabilir. FQDN, bağlantı dizenizde aşağıdaki gibi bulunabilir:

Endpoint=sb://mynamespace.servicebus.windows.net/;SharedAccessKeyName=XXXXXX;SharedAccessKey=XXXXXX

Event Hubs ad alanınız genel olmayan bir buluta dağıtıldıysa, etki alanı adınız farklı olabilir (örneğin, *.servicebus.chinacloudapi.cn, *.servicebus.usgovcloudapi.net veya *.servicebus.cloudapi.de).

Geçiş

Kafka istemci yapılandırmanızı güncelleştirme

Kafka özellikli bir Olay Hub'ına bağlanmak için Kafka istemci yapılandırmalarını güncelleştirmeniz gerekir. Kendi uygulamanızı bulma konusunda sorun yaşıyorsanız, uygulamanızda nerede bootstrap.servers ayarlandığını aramayı deneyin.

Aşağıdaki yapılandırmaları uygulamanızda anlamlı olan her yere ekleyin. İstemciyi bootstrap.servers doğru kimlik doğrulamasıyla Event Hubs Kafka uç noktanıza yönlendirmek için ve sasl.jaas.config değerlerini güncelleştirdiğinden emin olun.

bootstrap.servers={MYNAMESPACE}.servicebus.windows.net:9093
request.timeout.ms=60000
security.protocol=SASL_SSL
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="$ConnectionString" password="{CONNECTION STRING TO YOUR NAMESPACE}";

Çerçevenizde desteklenen bir yapılandırma değilse sasl.jaas.config SASL kullanıcı adını ve parolasını ayarlamak için kullanılan yapılandırmaları bulun ve bunları kullanın. Kullanıcı adını olarak $ConnectionString , parolayı ise Event Hubs bağlantı dizenize ayarlayın.

Geçiş sonrası

Olay hub'ına olay gönderen Kafka uygulamanızı çalıştırın. Ardından olay hub'sının olayları Azure portal kullanarak aldığını doğrulayın. Event Hubs ad alanınızın Genel Bakış sayfasında, Ölçümler bölümündeki İletiler görünümüne geçin. Grafiği güncelleştirmek için sayfayı yenileyin. İletilerin alındığını göstermesi birkaç saniye sürebilir.

Sonraki adımlar

Kafka için Event Hubs ve Event Hubs hakkında daha fazla bilgi edinmek için aşağıdaki makalelere bakın:

Aracılığıyla paylaş