Migrera till Azure Event Hubs i Apache Kafka-ekosystemen
Azure Event Hubs exponerar en Apache Kafka-slutpunkt, vilket gör att du kan ansluta till Event Hubs via Kafka-protokollet. Med minimala ändringar i ditt befintliga Kafka-program kan du ansluta till Azure Event Hubs och dra nytta av fördelarna med Azure-ekosystemet. Event Hubs fungerar med många av dina befintliga Kafka-program, inklusive MirrorMaker. Mer information finns i Event Hubs för Apache Kafka
Före migrering
Skapa ett Azure-konto
Om du inte har någon Azure-prenumeration kan du skapa ett kostnadsfritt konto innan du börjar.
Skapa ett Event Hubs-namnområde
Följ stegvisa instruktioner i artikeln Skapa en händelsehubb för att skapa en Event Hubs-namnrymd och en händelsehubb.
Anslutningssträng
Följ stegen i artikeln Hämta anslutningssträng från portalen . Anteckna anslutningssträngen för senare användning.
Fullständigt kvalificerat domännamn (FQDN)
Du kan också behöva det FQDN som pekar på händelsehubbens namnområde. FQDN finns i anslutningssträngen på följande sätt:
Endpoint=sb://mynamespace.servicebus.windows.net/;SharedAccessKeyName=XXXXXX;SharedAccessKey=XXXXXX
Om event hubs-namnområdet distribueras i ett icke-offentligt moln kan domännamnet skilja sig (till exempel *.servicebus.chinacloudapi.cn, *.servicebus.usgovcloudapi.net eller *.servicebus.cloudapi.de).
Migrering
Uppdatera Kafka-klientkonfigurationen
För att ansluta till en Kafka-aktiverad händelsehubb måste du uppdatera Kafka-klientkonfigurationerna. Om du har problem med att hitta din kan du prova att söka efter var bootstrap.servers som har angetts i ditt program.
Infoga följande konfigurationer var som helst där det är meningsfullt i ditt program. Se till att uppdatera bootstrap.servers värdena och sasl.jaas.config för att dirigera klienten till din Event Hubs Kafka-slutpunkt med rätt autentisering.
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}";
Om sasl.jaas.config inte är en konfiguration som stöds i ramverket hittar du de konfigurationer som används för att ange SASL-användarnamnet och lösenordet och använda dem i stället. Ange användarnamnet till $ConnectionString och lösenordet till din Event Hubs-anslutningssträng.
Efter migreringen
Kör ditt Kafka-program som skickar händelser till händelsehubben. Kontrollera sedan att händelsehubben tar emot händelserna med hjälp av Azure Portal. På sidan Översikt i Event Hubs-namnområdet växlar du till vyn Meddelanden i avsnittet Mått . Uppdatera sidan för att uppdatera diagrammet. Det kan ta några sekunder för det att visa att meddelandena har tagits emot.
Nästa steg
Mer information om Event Hubs och Event Hubs för Kafka finns i följande artiklar: