From the course: Stream Processing Design Patterns with Kafka Streams

Unlock this course with a free trial

Join today to access over 22,600 courses taught by industry experts.

Streaming analytics: Use case design

Streaming analytics: Use case design

- [Instructor] Let us design a sample Use Case for Streaming Analytics in this video. For example Use Case involves analyzing real-time orders. We have an eCommerce system that customers are placing orders. The orders will flow through a Kafka input topic The order is of JSON format. The input the simple, it contains an order ID, the name of the product, the quantity purchased and the price of each item. The goal for the Use Case is to analyze the order data every five seconds to compute product wise total value. This was done by multiplying the quantity with the price and aggregating across the window. Then the product wise five second summary should be returned to a MariaDB table. How does this design typology for Kafka streams look like? We will use a Kafka topic called streaming dot orders, dot input. We already created this topic in our Kafka setup. Then, we will convert the JSON input value from the Kafka message to…

Contents