page_type | languages | products | name | description | ||
---|---|---|---|---|---|---|
sample |
|
|
Sending and Receiving Message by Azure Event Hubs and Autoconfigured SDK Client in Spring Boot Application |
This sample demonstrates how to send and receive message by Azure Event Hubs and autoconfigured SDK client in Spring Boot application. |
Sending and Receiving Message by Azure Event Hubs and Autoconfigured SDK Client in Spring Boot Application
This code sample demonstrates how to use the client of Azure Event Hubs SDK
to interact with Azure Event Hubs
.
You will build an application that uses spring-cloud-azure-starter-eventhubs
to send and receive messages with Azure Event Hubs.
- An Azure subscription
- Terraform
- Azure CLI
- JDK8 or later
- Maven
- You can also import the code straight into your IDE:
This sample will create Azure resources using Terraform. If you choose to run it without using Terraform to provision resources, please pay attention to:
Important
If you choose to use a security principal to authenticate and authorize with Microsoft Entra ID for accessing an Azure resource please refer to Authorize access with Microsoft Entra ID to make sure the security principal has been granted the sufficient permission to access the Azure resource.
Terraform must authenticate to Azure to create infrastructure.
In your terminal, use the Azure CLI tool to setup your account permissions locally.
az login
Your browser window will open and you will be prompted to enter your Azure login credentials. After successful authentication, your terminal will display your subscription information. You do not need to save this output as it is saved in your system for Terraform to use.
You have logged in. Now let us find all the subscriptions to which you have access...
[
{
"cloudName": "AzureCloud",
"homeTenantId": "home-Tenant-Id",
"id": "subscription-id",
"isDefault": true,
"managedByTenants": [],
"name": "Subscription-Name",
"state": "Enabled",
"tenantId": "0envbwi39-TenantId",
"user": {
"name": "[email protected]",
"type": "user"
}
}
]
If you have more than one subscription, specify the subscription-id you want to use with command below:
az account set --subscription <your-subscription-id>
After login Azure CLI with your account, now you can use the terraform script to create Azure Resources.
# In the root directory of the sample
# Initialize your Terraform configuration
terraform -chdir=./terraform init
# Apply your Terraform Configuration
terraform -chdir=./terraform apply -auto-approve
# In the root directory of the sample
# Initialize your Terraform configuration
terraform -chdir=terraform init
# Apply your Terraform Configuration
terraform -chdir=terraform apply -auto-approve
It may take a few minutes to run the script. After successful running, you will see prompt information like below:
azurecaf_name.resource_group: Creating...
azurecaf_name.azurecaf_name_eventhubs: Creating...
...
azurerm_eventhub_namespace.eventhubs_namespace: Creating...
azurerm_eventhub_namespace.eventhubs_namespace: Still creating... [10s elapsed]
...
azurerm_eventhub.eventhubs: Creating...
azurerm_role_assignment.role_eventhubs_data_owner: Creating...
azurerm_role_assignment.role_eventhubs_data_owner: Still creating... [10s elapsed]
Apply complete! Resources: 6 added, 0 changed, 0 destroyed.
Outputs:
...
You can go to Azure portal in your web browser to check the resources you created.
Running the command below to export environment values:
source ./terraform/setup_env.sh
terraform\setup_env.ps1
If you want to run the sample in debug mode, you can save the output value.
AZURE_EVENTHUBS_NAMESPACE=...
AZURE_EVENTHUB_NAME=...
In your terminal, run mvn clean spring-boot:run
.
mvn clean spring-boot:run
You can debug your sample by adding the saved output values to the tool's environment variables or the sample's application.yaml
file.
-
If your tool is
IDEA
, please refer to Debug your first Java application and add environment variables. -
If your tool is
ECLIPSE
, please refer to Debugging the Eclipse IDE for Java Developers and Eclipse Environment Variable Setup.
- Verify in your app’s logs that similar messages were posted:
Sending message using Event Hub producer client.
Sent message to Event Hub.
Receiving message using Event Hub consumer client.
Received message: Test event
After running the sample, if you don't want to run the sample, remember to destroy the Azure resources you created to avoid unnecessary billing.
The terraform destroy command terminates resources managed by your Terraform project.
To destroy the resources you created.
terraform -chdir=./terraform destroy -auto-approve
terraform -chdir=terraform destroy -auto-approve
Now that you have the Spring Boot application running locally, it's time to move it to production. Azure Spring Apps makes it easy to deploy Spring Boot applications to Azure without any code changes. The service manages the infrastructure of Spring applications so developers can focus on their code. Azure Spring Apps provides lifecycle management using comprehensive monitoring and diagnostics, configuration management, service discovery, CI/CD integration, blue-green deployments, and more. To deploy your application to Azure Spring Apps, see Deploy your first application to Azure Spring Apps.