Migrieren zu Azure Event Hubs für Apache Kafka-Ökosysteme

Artikel
06/01/2023

Azure Event Hubs macht einen Apache Kafka-Endpunkt verfügbar, der es Ihnen ermöglicht, eine Verbindung mit Event Hubs herzustellen, indem Sie das Kafka-Protokoll verwenden. Durch minimale Änderungen an Ihrer vorhandenen Kafka-Anwendung können Sie eine Verbindung mit Azure Event Hubs herstellen und die Vorteile des Azure-Ökosystems nutzen. Event Hubs funktioniert mit vielen Ihrer vorhandenen Kafka-Anwendungen, einschließlich MirrorMaker. Weitere Informationen finden Sie unter Event Hubs für Apache Kafka.

Vor der Migration

Erstellen eines Azure-Kontos

Wenn Sie kein Azure-Abonnement besitzen, können Sie ein kostenloses Konto erstellen, bevor Sie beginnen.

Erstellen eines Event Hubs-Namespace

Befolgen Sie die schrittweise Anleitung in dem Artikel Erstellen eines Event Hubs, um einen Event Hubs-Namespace und einen Event Hub zu erstellen.

Verbindungszeichenfolge

Führen Sie die Schritte aus dem Artikel Abrufen einer Verbindungszeichenfolge aus dem Portal aus. Und notieren Sie sich die Verbindungszeichenfolge zur späteren Verwendung.

Vollqualifizierter Domänenname (FQDN)

Möglicherweise benötigen Sie auch den FQDN, der auf Ihren Event Hub-Namespace verweist. Den FQDN finden Sie innerhalb Ihrer Verbindungszeichenfolge wie folgt:

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

Wenn Ihr Event Hubs-Namespace in einer nicht öffentlichen Cloud bereitgestellt wird, kann Ihr Domänenname abweichen (z. B. *.servicebus.chinacloudapi.cn, *.servicebus.usgovcloudapi.net oder *.servicebus.cloudapi.de).

Migration

Aktualisieren Ihrer Kafka-Clientkonfiguration

Um eine Verbindung mit einem Kafka-fähigen Event Hub herzustellen, müssen Sie die Kafka-Clientkonfigurationen aktualisieren. Wenn Sie Probleme haben, Ihre zu finden, suchen Sie nach der Stelle, wo bootstrap.servers in Ihrer Anwendung festgelegt ist.

Fügen Sie die folgenden Konfigurationen dort ein, wo es in Ihrer Anwendung sinnvoll ist. Stellen Sie sicher, dass Sie die bootstrap.servers- und sasl.jaas.config-Werte so aktualisieren, dass sie den Client an Ihren Event Hubs Kafka-Endpunkt mit der richtigen Authentifizierung weiterleiten.

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

Wenn sasl.jaas.config in Ihrem Framework als Konfiguration nicht unterstützt wird, müssen Sie die Konfigurationen suchen, die zum Festlegen des SASL-Benutzernamens und -Kennworts verwendet werden, und diese stattdessen verwenden. Legen Sie den Benutzernamen auf $ConnectionString und das Kennwort auf Ihre Event Hubs-Verbindungszeichenfolge fest.

Nach der Migration

Führen Sie Ihre Kafka-Anwendung aus, die Ereignisse an den Event Hub sendet. Vergewissern Sie sich dann im Azure-Portal, dass der Event Hub die Ereignisse empfängt. Wechseln Sie auf der Seite Übersicht Ihres Event Hubs-Namespace zur Ansicht Nachrichten im Abschnitt Metrik. Aktualisieren Sie die Seite, um das Diagramm zu aktualisieren. Es kann einige Sekunden dauern, bis angezeigt wird, dass die Nachrichten empfangen wurden.

Nächste Schritte

Weitere Informationen zu Event Hubs und Event Hubs für Kafka finden Sie in folgenden Artikeln:

Freigeben über