Skip to content

A template to build a Kafka Stream processor using Quarkus

Notifications You must be signed in to change notification settings

ingvaar/kafka-quarkus-processor-template

Repository files navigation

kafka-quarkus-processor Project

This project uses Quarkus, the Supersonic Subatomic Java Framework.

If you want to learn more about Quarkus, please visit its website.

Running the application in dev mode

You can run your application in dev mode that enables live coding using:

./gradlew quarkusDev

NOTE: Quarkus now ships with a Dev UI, which is available in dev mode only.

Packaging and running the application

The application can be packaged using:

./gradlew build

It produces the quarkus-run.jar file in the build/quarkus-app/ directory. Be aware that it’s not an über-jar as the dependencies are copied into the build/quarkus-app/lib/ directory.

The application is now runnable using java -jar build/quarkus-app/quarkus-run.jar.

If you want to build an über-jar, execute the following command:

./gradlew build -Dquarkus.package.type=uber-jar

The application, packaged as an über-jar, is now runnable using java -jar build/*-runner.jar.

Creating a native executable

You can create a native executable using:

./gradlew build -Dquarkus.package.type=native

Or, if you don't have GraalVM installed, you can run the native executable build in a container using:

./gradlew build -Dquarkus.package.type=native -Dquarkus.native.container-build=true

You can then execute your native executable with: ./build/kafka-quarkus-processor-1.0.0-SNAPSHOT-runner

If you want to learn more about building native executables, please consult this guide.

Building the Docker image

You can create a standalone docker image using:

docker build . -t kafka-quarkus-processor

Configuration

On build configuration can be found in src/main/resources/application.properties.

Every configuration line can be set on runtime using env.

In this case, you have to replace every dots by an underscore: topic.in becomes TOPIC_IN.

Related Guides

  • Camel JSON Path (guide): Evaluate a JSONPath expression against a JSON message body
  • Kotlin (guide): Write your services in Kotlin
  • Camel Protobuf (guide): Serialize and deserialize Java objects using Google's Protocol buffers
  • Apache Kafka Streams (guide): Implement stream processing applications based on Apache Kafka
  • Micrometer metrics (guide): Instrument the runtime and your application with dimensional metrics using Micrometer.

About

A template to build a Kafka Stream processor using Quarkus

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published