Quarkus Kafka with SchemaRegistry

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

Kafka cluster

First you need a Kafka cluster and schema registry. You can follow the instructions from the Confluent Docker Image for Schema Registry or run

./src/main/docker/docker-compose up -d

if you have docker installed on your machine.

The application can be started using:

./mvnw compile quarkus:dev

Then, open your browser to http://localhost:8080/notifications/notify, to send message via kafka.

You can compile the application into a native binary using:

./mvnw clean package -Pnative

and run with:

./target/kafka-quickstart-1.0-SNAPSHOT-runner