Migrálás az Apache Kafka-ökoszisztémákhoz készült Azure Event Hubsba
Az Azure Event Hubs egy Apache Kafka végpontot tesz elérhetővé, amely lehetővé teszi, hogy a Kafka protokoll használatával csatlakozzon az Event Hubshoz. A meglévő Kafka-alkalmazása minimális módosításával csatlakozhat az Azure Event Hubshoz, és kihasználhatja az Azure-ökoszisztéma előnyeit. Az Event Hubs együttműködik számos meglévő Kafka-alkalmazással, köztük a MirrorMakerrel is. További információ: Event Hubs for Apache Kafka
A migrálás előtt
Azure-fiók létrehozása
Ha még nincs Azure-előfizetése, kezdés előtt hozzon létre egy ingyenes fiókot.
Event Hubs-névtér létrehozása
Az Event Hubs-névtér és egy eseményközpont létrehozásához kövesse az Eseményközpont létrehozása című cikkben található részletes utasításokat.
Kapcsolati sztring
Kövesse a Portál kapcsolati sztring lekérése című cikk lépéseit. Jegyezze fel a kapcsolati sztring későbbi használatra.
egy teljes tartománynév (FQDN)
Szükség lehet az eseményközpont-névtérre hivatkozó teljes tartománynévre is. Az FQDN a kapcsolati sztring belül található az alábbiak szerint:
Endpoint=sb://mynamespace.servicebus.windows.net/;SharedAccessKeyName=XXXXXX;SharedAccessKey=XXXXXX
Ha az Event Hubs-névtér nem nyilvános felhőben van üzembe helyezve, a tartományneve eltérhet (például *.servicebus.chinacloudapi.cn, *.servicebus.usgovcloudapi.net vagy *.servicebus.cloudapi.de).
Áttelepítés
A Kafka-ügyfél konfigurációjának frissítése
Egy Kafka-kompatibilis eseményközponthoz való csatlakozáshoz frissítenie kell a Kafka-ügyfélkonfigurációkat. Ha nem találja a sajátját, próbálja meg megkeresni, hogy hol bootstrap.servers van beállítva az alkalmazásban.
Szúrja be az alábbi konfigurációkat, bárhol is legyen értelme az alkalmazásban. Győződjön meg arról, hogy frissíti a és sasl.jaas.config az bootstrap.servers értékeket, hogy az ügyfelet a megfelelő hitelesítéssel az Event Hubs Kafka-végpontra irányítsa.
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}";
Ha sasl.jaas.config nem támogatott konfiguráció a keretrendszerben, keresse meg az SASL-felhasználónév és -jelszó beállításához és használatához használt konfigurációkat. Állítsa be a felhasználónevet és $ConnectionString a jelszót az Event Hubs kapcsolati sztring.
A migrálás után
Futtassa a Kafka-alkalmazást, amely eseményeket küld az eseményközpontba. Ezután ellenőrizze, hogy az eseményközpont fogadja-e az eseményeket a Azure Portal használatával. Az Event Hubs-névtér Áttekintés lapján váltson az Üzenetek nézetre a Metrikák szakaszban. Frissítse a lapot a diagram frissítéséhez. Néhány másodpercbe telhet, hogy megjelenjenek az üzenetek.
Következő lépések
Az Event Hubsról és a Kafkához készült Event Hubsról az alábbi cikkekben talál további információt: