Migrálás az Apache Kafka-ökoszisztémákhoz készült Azure Event Hubsba

Cikk
06/01/2023

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:

Share via