This repository contains an example for a distributed Pizza Store application using Kubernetes, Dapr, Spring Boot and Testcontainers to enable developers with a smooth developer experience.

You can run this application on any Kubernetes cluster by following the step-by-step instructions described in this document. Diagrid Conductor is used to monitor the health of the applications and get insights related to the Dapr configuration.

The Pizza Store application simulates placing a Pizza order that is going to be processed by different services. The application is composed by the Pizza Store Service which serves as the front-end and back-end to place the order. The order is sent to the Kitchen Service for preparation and once the order is ready to be delivered the Delivery Service takes the order to your door.

These services will need to store and read data from a state store, and exchange messages via a message broker to enable asynchronous communication. In this case Redis and Kafka are used, as these are well-known components among developers.

As you can see in the diagram, if we want to connect to Redis from the Pizza Store Service we need to add to our applications the Redis client that must match with the Redis instance version that we have available. A Kafka client is required in all the services that are interested in publishing or consuming messages/events. Because you have Drivers and Clients that are sensitive to the available versions on the infrastructure components, the lifecycle of the application is now bound to the lifecycle of these components.

Adding Dapr to the picture not only breaks these dependencies, but also remove responsibilities from developers of choosing the right Driver/Client and how these need to be configured for the application to work correctly. Dapr provides developers building block APIs such as the StateStore and PubSub API that developer can use without know the details of which infrastructure is going to be connected under the covers.

When using Dapr, developers can trust that the building block APIs are stable, while the teams in charge of the infrastructure can swap versions and services without impacting the application code or behavior.

1. For this demo you need a Diagrid Conductor account. Sign up for a free account at diagrid.io/conductor.
2. To run a kind cluster locally you need Docker Desktop, kind, and helm.

The demo comes with a front-end to place orders manually and see their progress. However, orders can also be placed direcly to the back-end with a REST client, such as the VS Code REST Client. To execute multiple order requests Ddosify can be used.

The easiest way to run the demo is to use the devcontainer and open it in VSCode (requires Docker Desktop) or in a GitHub Codespace. The devcontainer has the following preinstalled:

• kind & helm
• Ddosify
• VSCode REST client extension
• CodeTour extension

1. Once you have kind installed, you can run the following command to create a local cluster:

kind create cluster --config kind-config.yaml

kubectl cluster-info --context kind-test-cluster

2. In the Conductor dashboard, click the Connect Cluster button to configure a connection to your kubernetes cluster. Provide a name for the connection, choose Local for the Kubernetes distribution, and ensure to select Install Prerequisites and Install Dapr. Click Create to create the manifest file.

3. Copy the kubectl apply ... link and run it locally to apply the manifest.

kubectl apply -f "https://api.diagrid.io/apis/diagrid.io/v1beta1/clusters\<CLUSTER-ID\>manifests?token=\<TOKEN\>"

3. Check the progress of the Dapr pods creation:

kubectl get pods --all-namespaces

4. You can use Conductor to inspect the cluster health and the Dapr control plane uptime:

1. Redis is used as the key/value store that is used by the Dapr State Managemenr API. Install Redis via helm:

helm repo add bitnami https://charts.bitnami.com/bitnami
helm repo update
helm install redis bitnami/redis --set image.tag=6.2 --set replica.replicaCount=1

2. Kafka is used as the message broker for async communication between services. Install Kafka via helm:

helm install kafka oci://registry-1.docker.io/bitnamicharts/kafka --version 22.1.5 --set "provisioning.topics[0].name=events-topic" --set "provisioning.topics[0].partitions=1" --set "persistence.size=250Mi"

1. To install the services you only need to run the following command:

kubectl apply -f k8s/

This installs all the application services. To avoid dealing with Ingresses you can access the application by using kubectl port-forward, run to access the application on port 8080:

kubectl port-forward svc/pizza-store 8080:80

2. In Conductor switch to the Applications tab in the cluster to view the Dapr services:

Now you can choose to either make a pizza order via the front-end or run a script to make multiple orders.

Then you can point your browser to http://localhost:8080 and you should see:

Make a few orders and use the Conductor dashboard to inspect the metrics charts and get insights on the distributed application.

To execute many requests to the order endpoint you use Ddosify.

1. Update the IP address in the ddosify_order.json file.
2. Run bash run.sh in the root of this repo.

To execute individual requests use the test.rest file with the VSCode REST client.

Once several requests pizza orders have been made check the Apps Graph in Conductor to see the services and how they communicate:

You can isolate one service and check the connections with this service:

Note that the pizza-store-deployment application can have issues when running in a GitHub Codespace. This is because websocket connections can't be established in Codespaces. So when the pizza-store is receiving messages from the Kafka topic it can't forward these messages to the websocket connection properly, resulting in HTTP 500 errors. Use the App Notifications tab to inspect the metrics:

The application services are written using Java + Spring Boot. These services use the Dapr Java SDK to interact with the Dapr PubSub and Statestore APIs.

To run the services locally you can use the Testcontainer integration already included in the projects.

For example you can start a local version of the pizza-store service by running the following command inside the pizza-store/ directory (this requires having Java and Maven installed locally):

mvn spring-boot:test-run

This, not only start the pizza-store service, but it also uses the Testcontainers + Dapr Spring Boot integration to configure and wire up a Dapr configuration for local development. In other words, you can now use Dapr outside of Kubernetes, for writing your service tests without the need to know how Dapr is configured.

Once the service is up, you can place orders and simulate other events coming from the Kitchen and Delivery services by sending HTTP requests to the /events endpoint.

In the application you should see events that indicate the progress of the order.

Do you want to learn more about Conductor? Join the Diagrid Discourse where developers and platform engineers share knowledge on running distributed applications at scale with Dapr.