4.6 Using the Lab

Test your microservice

If your microservices are all up and running, open two tabs in your browser. View the kafka-viewer microservice on http://localhost:8082 and open up the Jaeger UI on http://localhost:16686 . The kafka-viewer will open up an active connection to your kafka topics and show you messages passing through the topics. In the Jaeger UI you can follow your traces through the system.

Now fire a request against the order API to create a new shop order. Let’s do a POST request to our /shop-orders endpoint and create a shop order with 2 pieces of article 1 and 3 pieces of article 2.

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16

curl --request POST \
  --url http://localhost:8080/shop-orders \
  --header 'Content-Type: application/json' \
  --data '{
  "articleOrders": [
    {
      "articleId": 1,
      "amount": 2
    },
    {
      "articleId": 2,
      "amount": 3
    }
  ]
}'

Check your browser and see what insights the kafka-viewer and the Jaeger UI give us. You can clearly see where the event was passing through our system in the Jaeger UI. The trace passes from the order microservices’ ShopOrderResource REST resource to the shop-order-request topic on kafka (seen in the kafka viewer) with some content like:

1

{"articleOrders":[{"amount":2,"articleId":1},{"amount":3,"articleId":2}],"id":100017}

Will then be passed to the shop-order-confirmation topic to be again confirmed by the order microservice! Our workflow now works.

Task 4.6.1 - Follow your traces through the code

Can you follow the traced produced and observed in the Jaeger UI through your own code?

Task 4.6.2 - Compensation instead of confirmations

Can you try to get a compensation event to test your compensation workflow as well? Try to provoke an error to make the stock microservice deny the order!

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16

curl --request POST \
  --url http://localhost:8080/shop-orders \
  --header 'Content-Type: application/json' \
  --data '{
  "articleOrders": [
    {
      "articleId": 1,
      "amount": 20
    },
    {
      "articleId": 2,
      "amount": 30
    }
  ]
}'

Task 4.6.3 - Observability test

Can you identify where the problem was in the previous request by just using our observability stack?

Task 4.6.4 - Enhance and Test observability (optional)

Your task now is to enhance the observability in your order microservice. We would like to see metrics to see how many messages we produce and consume in the microservice. In order to do this you will add metrics to your microservice to track:

• order_requests_produced
• order_confirmation_consumed
• order_compensation_consumed

Hint: In other labs you have already exposed custom metrics. Try to implement your own now!

1
2
3
4
5
6

    @Counted(name = "kafka_order_requested", absolute = true, description = "number of orders requested", tags = {"application=kafka-order"})
    @Traced
    public void createRequest(ShopOrderDTO shopOrderDTO) {
          ...
        }
    }

Can you identify with your newly implemented metrics after rebuilding and rerunning your system how many messages were confirmed and compensated after some requests?