الترحيل إلى Azure Event Hubs لـ Apache Kafka Ecosystems

يعرض Azure Event Hubs نقطة نهاية Apache Kafka، والتي تمكنك من الاتصال بـ Event Hubs باستخدام بروتوكول Kafka. من خلال إجراء الحد الأدنى من التغييرات على تطبيق Kafka الحالي، يمكنك الاتصال بـ Azure Event Hubs والاستمتاع بنظام Azure البيئي. تعمل Event Hubs مع العديد من تطبيقات Kafka الحالية، بما في ذلك MirrorMaker. لمزيد من المعلومات، راجع Event Hubs لـ Apache Kafka

ما قبل الترحيل

إنشاء حساب Azure

إذا لم يكن لديك اشتراك Azure، فأنشئ حساباً مجانياً قبل أن تبدأ.

إنشاء مساحة اسم مراكز الأحداث

اتبع الإرشادات خطوة بخطوة في مقالة إنشاء مركز أحداث لإنشاء مساحة اسم لـ Event Hubs ومركز أحداث.

سلسلة الاتصال

اتبع الخطوات الواردة في مقالة الحصول على سلسلة اتصال من المدخل. وقم بتدوين سلسلة الاتصال لاستخدامها لاحقاً.

اسم المجال المؤهل بالكامل (FQDN)

قد تحتاج أيضاً إلى FQDN الذي يشير إلى مساحة اسم Event Hub. يمكن العثور على FQDN ضمن سلسلة الاتصال الخاصة بك على النحو التالي:

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

إذا وُزِّعت مساحة اسم مراكز الأحداث على سحابة غير عامة، فقد يختلف اسم المجال الخاص بك (على سبيل المثال، *.servicebus.chinacloudapi.cn, أو *.servicebus.usgovcloudapi.net, أو *.servicebus.cloudapi.de).

الترحيل

تحديث تكوين عميل Kafka

للاتصال بـ Event Hub ممكّن لـ Kafka، ستحتاج إلى تحديث تكوينات عميل Kafka. إذا كنت تواجه مشكلة في العثور على التطبيق الخاص بك، فحاول البحث عن مكان تعيين bootstrap.servers في تطبيقك.

أدخل التكوينات التالية حيثما كان ذلك منطقياً في تطبيقك. تأكد من تحديث قيمتي bootstrap.servers وsasl.jaas.config لتوجيه العميل إلى نقطة نهاية Event Hubs Kafka باستخدام المصادقة الصحيحة.

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}";

إذا لم يكن sasl.jaas.config تكويناً مدعوماً في إطار العمل الخاص بك، فابحث عن التكوينات المستخدمة لتعيين اسم مستخدم وكلمة مرور SASL واستخدمها بدلاً من ذلك. قم بتعيين اسم المستخدم على $ConnectionString وكلمة المرور لسلسلة اتصال Event Hubs.

ما بعد الترحيل

قم بتشغيل تطبيق Kafka الخاص بك الذي يرسل الأحداث إلى مركز الحدث. بعد ذلك، تحقق من أن مركز الحدث يتلقى الأحداث باستخدام مدخل Microsoft Azure. في صفحة نظرة عامة لمساحة اسم Event Hubs، قم بالتبديل إلى عرض الرسائل في قسم القياسات. أعد تنشيط الصفحة لتحديث المخطط. وقد يستغرق إظهار تلقي الرسائل بضع ثوانٍ.

تحقق من أن مركز الأحداث تلقى الرسائل

الخطوات التالية

لمعرفة المزيد حول مراكز الأحداث ومراكز الأحداث لـ Kafka، راجع المقالات التالية: