Zelfstudie: Een Spring Boot-app implementeren die is verbonden met Apache Kafka in Confluent Cloud met Service Connector in Azure Spring Apps

Leer hoe je toegang krijgt tot Apache Kafka op Confluent Cloud voor een Spring Boot-toepassing op Azure Spring Apps. In deze zelfstudie voert u de volgende taken uit:

Apache Kafka maken in Confluent Cloud
Een Spring Cloud-toepassing maken
De Spring Boot-app bouwen en implementeren
Apache Kafka in Confluent Cloud verbinden met Azure Spring Apps met behulp van Service Connector

Note

De Basic, Standarden Enterprise--plannen zijn op 17 maart 2025 buiten gebruik gesteld. Zie de aankondiging over buitengebruikstelling van Azure Spring Apps voor meer informatie.

Warning

Microsoft raadt u aan de veiligste verificatiestroom te gebruiken die beschikbaar is. De verificatiestroom die in deze procedure wordt beschreven, vereist een zeer hoge mate van vertrouwen in de toepassing en brengt risico's met zich mee die niet aanwezig zijn in andere stromen. U moet deze stroom alleen gebruiken wanneer andere veiligere stromen, zoals beheerde identiteiten, niet haalbaar zijn.

Prerequisites

Een Azure-account met een actief abonnement. Gratis een account maken
Java 8 of een recentere versie met langetermijnondersteuning (LTS) 1.

Gebruik de Bash-omgeving in Azure Cloud Shell. Zie Aan de slag met Azure Cloud Shell voor meer informatie.
Als je de voorkeur geeft aan het lokaal uitvoeren van CLI-referentiecommando's, installeer dan de Azure CLI. Als je op Windows of macOS werkt, overweeg dan om Azure CLI in een Docker-container uit te voeren. Voor meer informatie, zie Hoe u de Azure CLI in een Docker-container kunt uitvoeren.
- Als u een lokale installatie gebruikt, meldt u zich aan bij Azure CLI met de opdracht az login. Om het authenticatieproces te voltooien, volgt u de stappen die op uw terminal worden weergegeven. Zie Verifiëren bij Azure met behulp van Azure CLI voor andere aanmeldingsopties.
- Wanneer u daarom wordt gevraagd, installeer de Azure CLI-extensie bij het eerste gebruik. Zie Extensies gebruiken en beheren met de Azure CLIvoor meer informatie over extensies.
- Voer az version uit om de geïnstalleerde versie en de afhankelijke bibliotheken te vinden. Voer az upgrade uit om naar de nieuwste versie te upgraden.

De voorbeeld-app klonen of downloaden

Kloon de voorbeeldopslagplaats:

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

Navigeer naar de volgende map:

cd serviceconnector-springcloud-confluent-springboot

Cloudservices voorbereiden

Een exemplaar van Apache Kafka maken voor Confluent Cloud

Maak een exemplaar van Apache Kafka voor Confluent Cloud door deze richtlijnen te volgen.

Kafka-cluster en schemaregister maken in Confluent Cloud

Meld u aan bij Confluent Cloud met behulp van de eenmalige aanmelding van Azure
De standaardomgeving gebruiken of een nieuwe maken
Maak een Kafka-cluster met de volgende informatie:
- Clustertype: Standaard
- Regio/zones: eastus(Virginia), enkele zone
- Clusternaam: cluster_1 of een andere naam.
Noteer in clusteroverzicht ->Clusterinstellingen de URL van de Kafka Bootstrap-server.
Maak API-sleutels voor het cluster in Gegevensintegratie ->API-sleutels ->+ Sleutel toevoegen met globale toegang. Noteer de sleutel en het geheim.
Een onderwerp maken met de naam test partities 6 in Onderwerpen ->+ Onderwerp toevoegen
Selecteer onder de standaardomgeving het tabblad Schemaregister . Schakel het schemaregister in en noteer het API-eindpunt.
API-sleutels maken voor schemaregister. Sla de sleutel en het geheim op.

Een Azure Spring Apps-exemplaar maken

Maak een exemplaar van Azure Spring Apps door de quickstart van Azure Spring Apps in Java te volgen. Zorg ervoor dat uw Azure Spring Apps-exemplaar is gemaakt in een regio met serviceconnectorondersteuning.

De app bouwen en implementeren

De voorbeeld-app bouwen en een nieuwe spring-app maken

Meld u aan bij Azure en kies uw abonnement.

az login

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

Bouw het project met Gradle.
```
./gradlew build
```
Maak de app waaraan een openbaar eindpunt is toegewezen. Als u Java-versie 11 hebt geselecteerd bij het genereren van het Spring Cloud-project, neemt u de --runtime-version=Java_11 switch op.
```
az spring app create -n hellospring -s <service-instance-name> -g <your-resource-group-name> --assign-endpoint true
```

Een serviceverbinding maken met serviceconnector

CLI
Portal

Voer de volgende opdracht uit om uw Apache Kafka in Confluent Cloud te verbinden met uw Spring Cloud-app.

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>

Vervang de volgende tijdelijke aanduidingen door uw eigen gegevens:

Vervang <your-resource-group-name> door de naam van de resourcegroep die u hebt aangemaakt voor uw Spring Apps-exemplaar.
Vervang door <kafka-bootstrap-server-url> de URL van uw Kafka bootstrap-server. Voorbeeld: pkc-xxxx.eastus.azure.confluent.cloud:9092.
Vervang <cluster-api-key> en <cluster-api-secret> door uw cluster-API-sleutel en -geheim.
Vervang <kafka-schema-registry-endpoint> met uw Kafka Schema Registry-eindpunt. Voorbeeld: https://psrc-xxxx.westus2.azure.confluent.cloud.
Vervang <registry-api-key> en <registry-api-secret> door uw kafka Schema Registry API-sleutel en geheim.

Note

Als u het foutbericht 'Het abonnement is niet geregistreerd voor gebruik van Microsoft.ServiceLinker' ziet, voert u az provider register -n Microsoft.ServiceLinker uit om de Service Connector resourceprovider te registreren en voert u de verbindingsopdracht opnieuw uit.

Selecteer Serviceconnector en voer de volgende instellingen in.

Setting	Voorgestelde waarde	Description
Servicetype	Apache Kafka op Confluent Cloud	Doelservicetype. Als u geen Apache Kafka in Confluent Cloud-doelservice hebt, voert u de vorige stappen in deze zelfstudie uit.
Name	Gegenereerde unieke naam	De verbindingsnaam waarmee de verbinding tussen uw Spring Cloud en de doelservice wordt geïdentificeerd.
Kafka bootstrap-server-url	De URL van uw Kafka bootstrap-server.	Voer de waarde uit eerdere stap in: 'Kafka-cluster en schemaregister maken in Confluent Cloud'.
Cluster-API-sleutel	Uw cluster-API-sleutel.	Uw cluster-API-sleutel.
Cluster-API-geheim	Uw cluster-API-geheim.	Uw cluster-API-geheim.
Verbinding maken voor schemaregister	Checked	Maak ook een verbinding met het schemaregister.
Schemaregister-eindpunt	Uw Kafka Schema Registry-eindpunt.
Api-sleutel voor schemaregister	Uw Kafka Schema Registry API-sleutel.	Uw Kafka Schema Registry API-sleutel.
Schema Registry API-geheim	Uw Kafka Schema Registry API sleutel.	Uw Kafka Schema Registry API sleutel.

Selecteer Beoordelen en maken om de verbindingsinstellingen te controleren. Selecteer Maken om te beginnen met het maken van de serviceverbinding.

Het JAR-bestand implementeren

Voer de volgende opdracht uit om het JAR-bestand (build/libs/java-springboot-0.0.1-SNAPSHOT.jar) te uploaden naar uw Spring Cloud-app.

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

De Gegevensopname van Kafka valideren

Navigeer vanuit Azure Portal naar het eindpunt van uw Spring Cloud-app en selecteer de toepassings-URL. U ziet '10 berichten zijn geproduceerd voor onderwerptest'.

Ga vervolgens naar de Confluent-portal en op de pagina van het onderwerp wordt de productiedoorvoer weergegeven.

Volgende stappen

Volg de onderstaande zelfstudies voor meer informatie over Service Connector.

Meer informatie over serviceconnectorconcepten

Feedback

Is deze pagina nuttig?

Last updated on 2025-10-08