Kafka Streams with Quarkus Twitter

CircleCI

SonarCloud Bugs Coverage Lines of Code

This repository is related with the article: Kafka Streams with Quarkus.

It shows how to build a simple stock market application that consumes Kafka Streams.

The following picture illustrates our architecture:


Run locally

Usage

You need to have Maven, JDK11+ and Docker (or Testcontainers Cloud Agent) installed on your local machine.

First, run the order-service:

cd order-service
mvn quarkus:dev

It will automatically start Kafka using Redpanda (Kafka API compatible platform).
Then, run the stock-service:

cd stock-service
mvn quarkus:dev

Observe the logs.
You can access Quarkus Dev UI console: http://localhost:8080/q/dev.
You can also call some REST endpoints with analytical data:

$ curl http://localhost:8080/transactions/products
$ curl http://localhost:8080/transactions/products/3
$ curl http://localhost:8080/transactions/products/5