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 skapar du ett kostnadsfritt konto innan du börjar.
Skapa ett Event Hubs-namnområde
Om du vill skapa ett Event Hubs-namnområde och en händelsehubb följer du stegvisa instruktioner i artikeln Skapa en händelsehubb .
Connection string
Följ stegen i artikeln: Hämta anslutningssträng från portalen. Anteckna anslutningssträng för senare användning.
Fullständigt kvalificerat domännamn (FQDN)
Du kan också behöva det fullständiga domännamnet som pekar på ditt Event Hubs-namnområde. FQDN finns i din anslutningssträng på följande sätt:
Endpoint=sb://mynamespace.servicebus.windows.net/;SharedAccessKeyName=XXXXXX;SharedAccessKey=XXXXXX
Om ditt Event Hubs-namnområde distribueras i ett icke-offentligt moln kan domännamnet skilja sig åt (till exempel *.servicebus.chinacloudapi.cn, *.servicebus.usgovcloudapi.net eller *.servicebus.cloudapi.de).
Migrering
Uppdatera kafka-klientkonfigurationen
Om du vill ansluta till en Kafka-aktiverad händelsehubb måste du uppdatera Kafka-klientkonfigurationerna. Om du har problem med att hitta din kan du försöka söka efter var bootstrap.servers som har angetts i ditt program.
Infoga följande konfigurationer där det är lämpligt 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 det inte finns någon konfiguration som stöds i ramverket hittar du de konfigurationer som används för att ange användarnamnet och lösenordet för SASL (Simple Authentication and Security Layer) och använder 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 innan det visar att meddelandena tas emot.
Nästa steg
Mer information om Event Hubs och Event Hubs för Kafka finns i följande artiklar: