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 geen Azure-abonnement hebt, maakt u een gratis account voordat u begint.
Een Event Hubs-naamruimte maken
Als u een Event Hubs-naamruimte en een Event Hub wilt maken, volgt u de stapsgewijze instructies in het artikel Een Event Hub maken.
Connection string
Volg de stappen in het artikel: Download verbindingsreeks vanuit de portal. Noteer de verbindingsreeks voor later gebruik.
FQDN (Fully Qualified Domain Name)
Mogelijk hebt u ook de FQDN nodig die verwijst naar uw Event Hubs-naamruimte. De FQDN vindt u als volgt in uw verbindingsreeks:
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 met Kafka-functionaliteit, moet u de Kafka-clientconfiguraties bijwerken. Als u problemen ondervindt bij het vinden van uw gebruikers, zoekt u naar de locatie die bootstrap.servers is ingesteld in uw toepassing.
Voeg de volgende configuraties in waar deze zich ook in uw toepassing bevinden. Zorg ervoor dat u de bootstrap.servers en sasl.jaas.config waarden bijwerkt om de client naar uw Event Hubs Kafka-eindpunt te leiden met de juiste verificatie.
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 dit geen ondersteunde configuratie in uw framework is, zoekt u de configuraties die worden gebruikt voor het instellen van de SASL-gebruikersnaam en -wachtwoord (Simple Authentication and Security Layer) en gebruikt u deze in plaats daarvan. Stel de gebruikersnaam $ConnectionString en het wachtwoord in op uw Event Hubs-verbindingsreeks.
Postmigratie
Voer uw Kafka-toepassing uit waarmee gebeurtenissen naar de Event Hub worden verzonden. Controleer vervolgens of de Event Hub de gebeurtenissen ontvangt met behulp van Azure Portal. Schakel op de pagina Overzicht van uw Event Hubs-naamruimte over naar de weergave Berichten in de sectie Metrische gegevens. U moet de pagina vernieuwen om de grafiek bij te werken. Het kan enkele seconden duren voordat wordt aangegeven dat de berichten zijn ontvangen.
Volgende stappen
Zie de volgende artikelen voor meer informatie over Event Hubs en Event Hubs voor Kafka: