quarkus-saga

Implementing the Saga Pattern in quarkus using quarkus-lra.

The LRA (short for Long Running Action) participant extension is useful in microservice based designs where different services can benefit from a relaxed notion of distributed consistency.

When booking a trip (a flight and a hotel), the payment service has an induced error rate which causes compensating actions.

In the successful case you will see a BOOKING and a PAYMENT for both the HOTEL and FLIGHT service.

Running locally

Run kafka cluster

podman-compose up -d

(Optional) Create kafka topics

add_path /opt/kafka_2.13-3.1.0/bin
kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic bookings
kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic payments

Check

kafkacat -b localhost:9092 -L

Watch processed topic

kafkacat -b localhost:9092 -t bookings -o beginning -C -f '\nKey (%K bytes): %k
Value (%S bytes): %s
Timestamp: %T
Partition: %p
Offset: %o
Headers: %h'

kafkacat -b localhost:9092 -t payments -o beginning -C -f '\nKey (%K bytes): %k
Value (%S bytes): %s
Timestamp: %T
Partition: %p
Offset: %o
Headers: %h'

Install data-library

cd data-library && mvn clean package install

Package Apps

mvn clean package

Run lra coordinator

java -Dquarkus.http.port=50000 -jar narayana-lra-coordinator/target/quarkus-app/quarkus-run.jar &

Run Apps using dev profile locally

java -Dquarkus.profile=dev -jar ./flight-service/target/quarkus-app/quarkus-run.jar
java -Dquarkus.profile=dev -jar ./hotel-service/target/quarkus-app/quarkus-run.jar
java -Dquarkus.profile=dev -jar ./payment-service/target/quarkus-app/quarkus-run.jar
java -Dquarkus.profile=dev -jar ./booking-service/target/quarkus-app/quarkus-run.jar

Book a trip

curl -s -vv -H 'accept: */*' http://localhost:8080/trip/book | jq .

Make individual flight, hotel, payment for testing

curl -s -XPOST -H 'Content-Type: application/json' http://localhost:8081/hotel/buy -d '{ "item": "hotel", "customerId": "mike", "quantity": 1, "price": 100.00 }' | jq .
curl -s -XPOST -H 'Content-Type: application/json' http://localhost:8082/flight/buy -d '{ "item": "flight", "customerId": "mike", "quantity": 1, "price": 100.00 }' | jq .
curl -s -XPOST -H 'Content-Type: application/json' http://localhost:8083/payment/pay -d '{ "item": "flight", "customerId": "mike", "quantity": 1, "price": 100.00 }' | jq .

Check LRA - should be empty if no failures

curl -s http://localhost:50000/lra-coordinator | jq .

Testing Failures

Introduce some random failure into the payment service:

diff --git a/payment-service/src/main/java/org/acme/PaymentService.java b/payment-service/src/main/java/org/acme/PaymentService.java
index 94a6293..4f63c47 100644
--- a/payment-service/src/main/java/org/acme/PaymentService.java
+++ b/payment-service/src/main/java/org/acme/PaymentService.java
@@ -59,8 +59,8 @@ public class PaymentService {
     public Response pay(@HeaderParam(LRA_HTTP_CONTEXT_HEADER) URI lraId, Purchase purchase) {
         purchase.setItem("PAYMENT# ".concat(purchase.getItem()));
         log.info(">>> Payment received for LRA {} and Purchase {}", lraId, purchase);
-//        if (new SecureRandom().nextBoolean())
-//            return Response.serverError().build();
+        if (new SecureRandom().nextBoolean())
+            return Response.serverError().build();
         payments.send(KafkaRecord.of(lraId, purchase));
         JsonObject response = new JsonObject().put("message", "Payment Made LRA #" + lraId);
         response.put("purchase", JsonObject.mapFrom(purchase));

Rebuild payment-service and restart it

cd payment-service && mvn clean package
java -Dquarkus.profile=dev -jar ./payment-service/target/quarkus-app/quarkus-run.jar

Now when a failure happens, you should see compensating actions (CANCEL of bookings and payments) in the Kafka (bookings, payments) topics.

OpenShift

This creates a demo in the quarkus-saga namespace.

Deploy kafka operator as cluster-admin

kustomize build amq-streams/base | oc apply -f-

Deploy kafka CR

kustomize build amq-streams/dev | oc apply -f-

Deploy apps from quay.io

oc -n quarkus-saga new-app quay.io/eformat/narayana-lra-coordinator
oc -n quarkus-saga new-app quay.io/eformat/payment-service
oc -n quarkus-saga new-app quay.io/eformat/flight-service
oc -n quarkus-saga new-app quay.io/eformat/hotel-service
oc -n quarkus-saga new-app quay.io/eformat/booking-service
oc -n quarkus-saga expose service/booking-service

Demo - port forward kafka locally

oc -n quarkus-saga run tools --image=debezium/tooling --command -- bash -c 'sleep infinity'
oc -n quarkus-saga rsh tools
kafkacat -b quarkus-saga-cluster-kafka-bootstrap:9092 -L

Watch processed topic

kafkacat -b quarkus-saga-cluster-kafka-bootstrap:9092 -t bookings -o beginning -C -f '\nKey (%K bytes): %k
Value (%S bytes): %s
Timestamp: %T
Partition: %p
Offset: %o
Headers: %h'

kafkacat -b quarkus-saga-cluster-kafka-bootstrap:9092 -t payments -o beginning -C -f '\nKey (%K bytes): %k
Value (%S bytes): %s
Timestamp: %T
Partition: %p
Offset: %o
Headers: %h'

Book a trip

curl -s -vv -H 'accept: */*' $(oc -n quarkus-saga get routes booking-service -o jsonpath='http://{.spec.host}/')/trip/book | jq .

Redeploy the image for payment-service that fails randomly:

oc tag --source=docker quay.io/eformat/payment-service:fail quarkus-saga/payment-service:latest --reference-policy=local --insecure=true

And put it back to normal:

oc tag --source=docker quay.io/eformat/payment-service:latest quarkus-saga/payment-service:latest --reference-policy=local --insecure=true

eformat/quarkus-saga

quarkus-saga

Running locally

Testing Failures

OpenShift