Kurz: Nasazení aplikace Spring Boot připojené k Apache Kafka v confluent cloudu s konektorem service v Azure Spring Apps

Zjistěte, jak získat přístup k Apache Kafka v Confluent Cloudu pro aplikaci Spring Boot spuštěnou v Azure Spring Apps. V tomto kurzu provedete následující úlohy:

• Vytvoření Apache Kafka v confluent cloudu
• Vytvoření aplikace Spring Cloud
• Sestavení a nasazení aplikace Spring Boot
• Připojení Apache Kafka v Confluent Cloudu ke službě Azure Spring Apps pomocí konektoru služeb

Upozorňující

Microsoft doporučuje používat nejbezpečnější dostupný tok ověřování. Ověřovací tok popsaný v tomto postupu vyžaduje velmi vysoký stupeň důvěryhodnosti v aplikaci a nese rizika, která nejsou přítomna v jiných tocích. Tento tok byste měli použít jenom v případě, že jiné bezpečnější toky, jako jsou spravované identity, nejsou přijatelné.

Požadavky

• Účet Azure s aktivním předplatným. Vytvoření účtu zdarma

• Java 8 nebo novější verze s dlouhodobou podporou (LTS) 1.

• Použijte prostředí Bash v Azure Cloud Shellu. Další informace najdete v tématu Rychlý start pro Bash v Azure Cloud Shellu.

  

• Pokud dáváte přednost místnímu spouštění referenčních příkazů rozhraní příkazového řádku, nainstalujte Azure CLI. Pokud používáte Windows nebo macOS, zvažte spuštění Azure CLI v kontejneru Docker. Další informace najdete v tématu Jak spustit Azure CLI v kontejneru Dockeru.

  • Pokud používáte místní instalaci, přihlaste se k Azure CLI pomocí příkazu az login. Pokud chcete dokončit proces ověřování, postupujte podle kroků zobrazených na terminálu. Další možnosti přihlášení najdete v tématu Přihlášení pomocí Azure CLI.

  • Po zobrazení výzvy nainstalujte rozšíření Azure CLI při prvním použití. Další informace o rozšířeních najdete v tématu Využití rozšíření v Azure CLI.

  • Spuštěním příkazu az version zjistěte verzi a závislé knihovny, které jsou nainstalované. Pokud chcete upgradovat na nejnovější verzi, spusťte az upgrade.

Klonování nebo stažení ukázkové aplikace

1. Naklonujte ukázkové úložiště:

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

2. Přejděte do následující složky:

   cd serviceconnector-springcloud-confluent-springboot
   

Příprava cloudových služeb

Vytvoření instance Apache Kafka pro Confluent Cloud

Podle těchto pokynů vytvořte instanci Apache Kafka pro Confluent Cloud.

Vytvoření clusteru Kafka a registru schématu v confluent cloudu

1. Přihlášení ke cloudu Confluent pomocí jednotného přihlašování poskytovaného Azure

   

2. Použijte výchozí prostředí nebo vytvořte nové.

   

3. Vytvořte cluster Kafka s následujícími informacemi:

   • Typ clusteru: Standard
   • Oblast/zóny: eastus(Virginia), jedna zóna
   • Název clusteru: cluster_1 nebo jiný název.

4. V přehledu clusteru –> Nastavení clusteru si poznamenejte adresu URL serveru Kafka Bootstrap.

   

5. Vytvořte klíče rozhraní API pro cluster v integraci dat ->API Keys ->+ Přidat klíč s globálním přístupem. Poznamenejte si klíč a tajný klíč.

6. Vytvoření tématu s názvem test oddíly 6 v tématech –> + Přidat téma

7. Ve výchozím prostředí vyberte kartu Registr schématu. Povolte registr schématu a poznamenejte si koncový bod rozhraní API.

8. Vytvořte klíče rozhraní API pro registr schématu. Uložte klíč a tajný klíč.

Vytvoření instance Azure Spring Apps

Pomocí rychlého startu Azure Spring Apps v Javě vytvořte instanci Azure Spring Apps. Ujistěte se, že je vaše instance Azure Spring Apps vytvořená v oblasti, která má podporu konektoru Service Connector.

Sestavení a nasazení aplikace

Vytvoření ukázkové aplikace a vytvoření nové springové aplikace

1. Přihlaste se k Azure a zvolte své předplatné.

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

2. Sestavte projekt pomocí gradle.

   ./gradlew build
   

3. Vytvořte aplikaci s přiřazeným veřejným koncovým bodem. Pokud jste při generování projektu Spring Cloud vybrali Javu verze 11, zahrňte přepínač --runtime-version=Java_11 .

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

Vytvoření připojení služby pomocí konektoru služby

Rozhraní příkazového řádku

Spuštěním následujícího příkazu připojte Apache Kafka v Confluent Cloudu k aplikaci Spring Cloud.

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>

Nahraďte následující zástupné texty vlastními daty:

• Nahraďte <your-resource-group-name> názvem skupiny prostředků, kterou jste vytvořili pro instanci Aplikace Spring Apps.
• Nahraďte <kafka-bootstrap-server-url> adresou URL vašeho serveru Kafka bootstrap. Například: pkc-xxxx.eastus.azure.confluent.cloud:9092.
• Nahraďte <cluster-api-key> klíč <cluster-api-secret> a tajný klíč rozhraní API clusteru.
• Nahraďte <kafka-schema-registry-endpoint> koncovým bodem registru schémat Kafka. Například: https://psrc-xxxx.westus2.azure.confluent.cloud.
• Nahraďte <registry-api-key> klíč a <registry-api-secret> tajný klíč rozhraní KAFKA Schema Registry API a tajným kódem.

Poznámka:

Pokud se zobrazí chybová zpráva "Předplatné není zaregistrované pro použití Microsoft.ServiceLinker", spusťte prosím az provider register -n Microsoft.ServiceLinker registraci poskytovatele prostředků konektoru služeb a spusťte příkaz pro připojení znovu.

Azure Portal

Vyberte Konektor služby a zadejte následující nastavení.

Nastavení	Navrhovaná hodnota	Popis
Typ služby	Apache Kafka v cloudu Confluent	Typ cílové služby. Pokud nemáte apache Kafka v cílové službě Confluent Cloudu, proveďte předchozí kroky v tomto kurzu.
Název	Vygenerovaný jedinečný název	Název připojení, který identifikuje propojení mezi vaší službou Spring Cloud a cílovou službou.
Adresa URL serveru Kafka bootstrap	Adresa URL vašeho serveru Kafka bootstrap.	Zadejte hodnotu z předchozího kroku: Vytvoření clusteru Kafka a registru schématu v Confluent Cloudu.
Klíč rozhraní API clusteru	Váš klíč rozhraní API clusteru.	Váš klíč rozhraní API clusteru.
Tajný kód rozhraní API clusteru	Tajný klíč rozhraní API clusteru.	Tajný klíč rozhraní API clusteru.
Vytvoření připojení pro registr schématu	Zkontrolováno	Vytvořte také připojení k registru schématu.
Koncový bod registru schématu	Koncový bod registru schématu Kafka.
Klíč rozhraní API registru schématu	Klíč rozhraní API registru schématu Kafka.	Klíč rozhraní API registru schématu Kafka.
Tajný klíč rozhraní API registru schématu	Tajný klíč rozhraní API registru schémat Kafka.	Tajný klíč rozhraní API registru schémat Kafka.

Výběrem možnosti Zkontrolovat a vytvořit zkontrolujte nastavení připojení. Pak vyberte Vytvořit a začněte vytvářet připojení služby.

Nasazení souboru JAR

Spuštěním následujícího příkazu nahrajte soubor JAR (build/libs/java-springboot-0.0.1-SNAPSHOT.jar) do aplikace Spring Cloud.

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

Ověření příjmu dat Kafka

Přejděte na koncový bod aplikace Spring Cloud z webu Azure Portal a vyberte adresu URL aplikace. Zobrazí se zpráva "10 zpráv bylo vytvořeno pro testování témat".

Pak přejděte na portál Confluent a na stránce tématu se zobrazí produkční propustnost.

Další kroky

Další informace o konektoru Service Connector najdete v následujících kurzech.

Další informace o konceptech konektoru Service Connector