End-to-end Scenario

Data change events from the Globex web application are captured by Debezium and produced to Kafka topics.

A Kafka Streams application combines and aggregates the data change event streams for orders and line_item at real time to produce a new stream of aggregated order events.

Camel K integrations consume from Kafka topics and call REST endpoints on the Cashback service, to build a local view of customers and orders, and calculate the cashback amounts.

In the browser window, open the tab pointing to the OpenShift console. If you don’t have a tab open to the console, click to navigate to {openshift_cluster_console}[OpenShift console, window="console"]. If needed login with your username and password ({user_name}/{user_password}). Select the Topology view in the Developer perspective and make sure you are on the globex-cdc-{user_name} namespace.

In the Topology view, locate the Cashback service deployment, and click on the Open URL symbol next to it.

This opens a browser window with the cashback UI, which shows the list of customers together with their earned cashbacks.

You should see some customers with a cashback greater than $0. You might need to advance through several pages if you don’t see any customers with a cashback value grater than 0$. If you still don’t see any, please simulate some orders as detailed earlier in this chapter.
Click on a cashback with value greater then $0. You should see the list of orders leading to the cashback.

At this point, you can demonstrate the end-to-end flow starting from creating an order in the Globex web application.