Migreren naar Azure Event Hubs voor Apache Kafka-ecosystemen
In Azure Event Hubs wordt een Apache Kafka-eindpunt weergegeven, zodat u met behulp van het Kafka-protocol verbinding kunt maken met Event Hubs. Door minimale wijzigingen aan te brengen in uw bestaande Kafka-toepassing, kunt u verbinding maken met Azure Event Hubs en profiteren van de voordelen van het Azure-ecosysteem. Event Hubs werkt met veel van uw bestaande Kafka-toepassingen, waaronder MirrorMaker. Zie Event Hubs voor Apache Kafka voor meer informatie
Premigratie
Een Azure-account maken
Als u nog geen abonnement op Azure hebt, maak dan een gratis account aan voordat u begint.
Een Event Hubs-naamruimte maken
Volg de stapsgewijze instructies in het artikel Een Event Hub maken om een Event Hubs-naamruimte en een Event Hub te maken.
Verbindingsreeks
Volg de stappen in het artikel Connection string ophalen uit de portal. Noteer ook de connection string voor later gebruik.
FQDN (Fully Qualified Domain Name)
Mogelijk hebt u ook de FQDN nodig die verwijst naar uw Event Hub-naamruimte. De FQDN vindt u als volgt in uw connection string:
Endpoint=sb://mynamespace.servicebus.windows.net/;SharedAccessKeyName=XXXXXX;SharedAccessKey=XXXXXX
Als uw Event Hubs-naamruimte is geïmplementeerd in een niet-openbare cloud, kan uw domeinnaam verschillen (bijvoorbeeld *.servicebus.chinacloudapi.cn, *.servicebus.usgovcloudapi.net of *.servicebus.cloudapi.de).
Migratie
Uw Kafka-clientconfiguratie bijwerken
Als u verbinding wilt maken met een Event Hub waarvoor Kafka is ingeschakeld, moet u de Kafka-clientconfiguraties bijwerken. Als u problemen ondervindt bij het vinden van de uwe, kunt u zoeken naar waar bootstrap.servers is ingesteld in uw toepassing.
Voeg de volgende configuraties in waar dit zinvol is in uw toepassing. Zorg ervoor dat u de bootstrap.servers waarden en sasl.jaas.config bijwerkt om de client met de juiste verificatie naar uw Event Hubs Kafka-eindpunt te leiden.
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}";
Als sasl.jaas.config geen ondersteunde configuratie in uw framework is, zoekt u de configuraties die worden gebruikt om de SASL-gebruikersnaam en -wachtwoord in te stellen en gebruikt u deze in plaats daarvan. Stel de gebruikersnaam in op $ConnectionString en het wachtwoord op uw Event Hubs-connection string.
Postmigratie
Voer uw Kafka-toepassing uit die gebeurtenissen naar de Event Hub verzendt. Controleer vervolgens of de Event Hub de gebeurtenissen ontvangt met behulp van de Azure Portal. Ga op de pagina Overzicht van uw Event Hubs-naamruimte naar de weergave Berichten in de sectie Metrische gegevens . U moet de pagina vernieuwen om de grafiek bij te werken. Het kan een paar seconden duren voordat wordt weergegeven dat de berichten zijn ontvangen.
Volgende stappen
Zie de volgende artikelen voor meer informatie over Event Hubs en Event Hubs voor Kafka: