Migrieren zu Azure Event Hubs für Apache Kafka-Ökosysteme
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 ausführlichen Anweisungen im Artikel Erstellen eines Event Hubs, um einen Event Hubs-Namespace und einen Event Hub zu erstellen.
Connection string
Führen Sie die Schritte im 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 (Simple Authentication and Security Layer) 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 der Empfang der Nachrichten angezeigt wird.
Nächste Schritte
Weitere Informationen zu Event Hubs und Event Hubs für Kafka finden Sie in folgenden Artikeln: