Oktatóanyag: Az Apache Kafkához csatlakoztatott Spring Boot-alkalmazás üzembe helyezése a Confluent Cloudon service Csatlakozás or használatával az Azure Spring Appsben

Megtudhatja, hogyan férhet hozzá az Apache Kafka-hoz a Confluent Cloudon az Azure Spring Appsen futó Spring Boot-alkalmazásokhoz. Az oktatóanyagban az alábbi feladatokat fogja végrehajtani:

• Apache Kafka létrehozása a Confluent Cloudon
• Spring Cloud-alkalmazás létrehozása
• A Spring Boot-alkalmazás létrehozása és üzembe helyezése
• Csatlakozás Apache Kafka a Confluent Cloudon az Azure Spring Appsbe a Service Csatlakozás or használatával

Előfeltételek

• Egy Azure-fiók, aktív előfizetéssel. Fiók ingyenes létrehozása.

• Java 8 vagy újabb verzió hosszú távú támogatással (LTS) 1.

• Használja a Bash-környezetet az Azure Cloud Shellben. További információ: A Bash rövid útmutatója az Azure Cloud Shellben.

  

• Ha inkább helyi cli-referenciaparancsokat szeretne futtatni, telepítse az Azure CLI-t. Ha Windows vagy macOS rendszert használ, fontolja meg az Azure CLI Docker-tárolóban való futtatását. További információ: Az Azure CLI futtatása Docker-tárolóban.

  • Ha helyi telepítést használ, jelentkezzen be az Azure CLI-be az az login parancs futtatásával. A hitelesítési folyamat befejezéséhez kövesse a terminálon megjelenő lépéseket. További bejelentkezési lehetőségekért lásd : Bejelentkezés az Azure CLI-vel.

  • Amikor a rendszer kéri, először telepítse az Azure CLI-bővítményt. További információ a bővítményekről: Bővítmények használata az Azure CLI-vel.

  • Futtassa az az version parancsot a telepített verzió és a függő kódtárak megkereséséhez. A legújabb verzióra az az upgrade paranccsal frissíthet.

A mintaalkalmazás klónozása vagy letöltése

1. Klónozza a mintaadattárat:

   git clone https://github.com/Azure-Samples/serviceconnector-springcloud-confluent-springboot/
   

2. Lépjen a következő mappába:

   cd serviceconnector-springcloud-confluent-springboot
   

Felhőszolgáltatások előkészítése

Apache Kafka-példány létrehozása a Confluent Cloudhoz

Az útmutatót követve hozza létre az Apache Kafka for Confluent Cloud egy példányát.

Kafka-fürt és sémaregisztrációs adatbázis létrehozása a Confluent Cloudon

1. Bejelentkezés a Confluent Cloudba az Azure által biztosított egyszeri bejelentkezéssel

   

2. Az alapértelmezett környezet használata vagy új létrehozása

   

3. Hozzon létre egy Kafka-fürtöt a következő információkkal:

   • Fürt típusa: Standard
   • Régió/zónák: eastus(Virginia), Single Zone
   • Fürt neve: cluster_1 vagy bármely más név.

4. A Fürt áttekintése –>Fürt beállításai területen jegyezze fel a Kafka Bootstrap-kiszolgáló URL-címét.

   

5. API-kulcsok létrehozása a fürthöz az adatintegrációban –>API Keys –>+ Kulcs hozzáadása globális hozzáféréssel. Jegyezze fel a kulcsot és a titkos kulcsot.

6. 6. partíciókkal elnevezett test témakör létrehozása a témakörökben –>+ Témakör hozzáadása

7. Az alapértelmezett környezetben válassza a Sémaregisztrációs adatbázis lapot. Engedélyezze a sémaregisztrációs adatbázist, és jegyezze fel az API-végpontot.

8. API-kulcsok létrehozása sémaregisztrációs adatbázishoz. Mentse a kulcsot és a titkos kulcsot.

Azure Spring Apps-példány létrehozása

Hozzon létre egy Azure Spring Apps-példányt az Azure Spring Apps Java-beli gyorsútmutatójának követésével. Győződjön meg arról, hogy az Azure Spring Apps-példány olyan régióban lett létrehozva, amely rendelkezik service Csatlakozás or-támogatással.

Az alkalmazás létrehozása és üzembe helyezése

A mintaalkalmazás létrehozása és új tavaszi alkalmazás létrehozása

1. Jelentkezzen be az Azure-ba, és válassza ki az előfizetését.

   az login
   
   az account set --subscription <Name or ID of your subscription>
   

2. A projekt összeállítása a gradle használatával.

   ./gradlew build
   

3. Hozza létre az alkalmazást egy hozzárendelt nyilvános végponttal. Ha a Spring Cloud-projekt létrehozásakor a Java 11-es verzióját választotta, adja meg a kapcsolót --runtime-version=Java_11 .

   az spring app create -n hellospring -s <service-instance-name> -g <your-resource-group-name> --assign-endpoint true
   

Szolgáltatáskapcsolat létrehozása a Service Csatlakozás or használatával

Parancssori felület

Futtassa a következő parancsot az Apache Kafka Confluent Cloudon való csatlakoztatásához a spring cloud-alkalmazáshoz.

az spring connection create confluent-cloud -g <your-spring-cloud-resource-group> --service <your-spring-cloud-service> --app <your-spring-cloud-app> --deployment <your-spring-cloud-deployment> --bootstrap-server <kafka-bootstrap-server-url> --kafka-key <cluster-api-key> --kafka-secret <cluster-api-secret> --schema-registry <kafka-schema-registry-endpoint> --schema-key <registry-api-key> --schema-secret <registry-api-secret>

Cserélje le a következő helyőrző szövegeket a saját adataira:

• Cserélje le <your-resource-group-name> az Apps Spring Apps-példányhoz létrehozott erőforráscsoport-nevet.
• Cserélje le <kafka-bootstrap-server-url> a Kafka bootstrap-kiszolgáló URL-címét. Például: pkc-xxxx.eastus.azure.confluent.cloud:9092
• Cserélje le <cluster-api-key> és <cluster-api-secret> használja a fürt API-kulcsát és titkos kódját.
• Cserélje le <kafka-schema-registry-endpoint> a Kafka-sémaregisztrációs adatbázis végpontjára. Például: https://psrc-xxxx.westus2.azure.confluent.cloud
• Cserélje le <registry-api-key> és <registry-api-secret> használja a kafka Schema Registry API-kulcsát és titkos kódját.

Feljegyzés

Ha a "Az előfizetés nincs regisztrálva a Microsoft.ServiceLinker használatához" hibaüzenet jelenik meg, futtassa az provider register -n Microsoft.ServiceLinker a Service Csatlakozás or erőforrás-szolgáltató regisztrálásához, és futtassa újra a kapcsolati parancsot.

Portál

Válassza a Service Csatlakozás or lehetőséget, és adja meg a következő beállításokat.

Beállítás	Ajánlott érték	Leírás
Szolgáltatás típusa	Apache Kafka a Confluent-felhőben	Célszolgáltatás típusa. Ha nem rendelkezik Apache Kafkával a Confluent Cloud célszolgáltatáson, végezze el az oktatóanyag korábbi lépéseit.
Név	Létrehozott egyedi név	A Spring Cloud és a célszolgáltatás közötti kapcsolatot azonosító kapcsolat neve.
Kafka bootstrap-kiszolgáló URL-címe	A Kafka bootstrap-kiszolgáló URL-címe.	Adja meg a korábbi lépés értékét: "Kafka-fürt és sémaregisztrációs adatbázis létrehozása a Confluent Cloudon".
Fürt API-kulcsa	A fürt API-kulcsa.	A fürt API-kulcsa.
Fürt API-titkos kódja	A fürt API-titkos kódja.	A fürt API-titkos kódja.
Kapcsolat létrehozása sémaregisztrációs adatbázishoz	Jelölje be	Hozzon létre egy kapcsolatot a sémaregisztrációs adatbázissal is.
Sémaregisztrációs adatbázis végpontja	A Kafka-sémaregisztrációs adatbázis végpontja.
Sémaregisztrációs API-kulcs	A Kafka Schema Registry API-kulcsa.	A Kafka Schema Registry API-kulcsa.
Sémaregisztrációs API-titkos kód	A Kafka Schema Registry API-titkos kódja.	A Kafka Schema Registry API-titkos kódja.

Válassza a Véleményezés + Létrehozás lehetőséget a kapcsolati beállítások áttekintéséhez. Ezután válassza a Létrehozás lehetőséget a szolgáltatáskapcsolat létrehozásának megkezdéséhez.

A JAR-fájl üzembe helyezése

Futtassa a következő parancsot a JAR-fájl (build/libs/java-springboot-0.0.1-SNAPSHOT.jar) spring cloud-alkalmazásba való feltöltéséhez.

az spring app deploy -n hellospring -s <service-instance-name> -g <your-resource-group-name>  --artifact-path build/libs/java-springboot-0.0.1-SNAPSHOT.jar

A Kafka-adatok betöltésének ellenőrzése

Lépjen a Spring Cloud-alkalmazás végpontjára az Azure Portalon, és válassza ki az alkalmazás URL-címét. Ekkor megjelenik a "10 üzenet készült a témakörteszteléshez".

Ezután lépjen a Confluent portálra, és a témakör oldala megjeleníti az éles üzem átviteli sebességét.

Következő lépések

A Szolgáltatás Csatlakozás orról az alábbi oktatóanyagok alapján tájékozódhat.

Tudnivalók a Service Csatlakozás or fogalmairól