kafka-panache-quickstart

Quarkus Kafka/Panache Quickstart

This project illustrates how you can interact with Apache Kafka using MicroProfile Reactive Messaging and Hibernate with Panache.

Infrastructure

You need a PostgreSQL instance and a Kafka broker. To start them, just run docker-compose up -d.

Start the application

The application can be started using:

mvn quarkus:dev

Then, open your browser to http://localhost:8080/prices, and you should get the set of prices written in the database. Every 5 seconds, a new price is generated, sent to a Kafka topic, received by a Kafka consumer and written to the database. Refresh the page to see more prices.

Anatomy

• PriceGenerator - a bean generating random price. They are sent to a Kafka topic
• PriceStorage - on the consuming side, the PriceStorage receives the Kafka message and write it into the database using Hibernate with Panache
• PriceResource - the PriceResource retrieves the prices from the database and send them into the HTTP response

Running in native

You can compile the application into a native binary using:

mvn clean install -Pnative

and run with:

./target/kafka-panache-quickstart-1.0.0-SNAPSHOT-runner