Kafka Processor Dispatch Cosmos TX

Purpose

Kafka Streams Processor that consumes CØSMOS and OKP4 Protobuf messages from an input topic and dispatch them to output topics relying on routing rules.

Implementation

Implementation mainly relies on Kafka Streams API, library to create event-stream applications with the following features:

• no external dependency other than Kafka itself,
• simple and light library,
• fault-tolerant and scalable.

Moreover, this implementation:

• uses Kotkin as primary coding language,
• uses Quarkus to minimize resources consumption,
• is as much as possible, lean, i.e. tries to minimize the dependencies to 3rd party libraries and the resulting package footprint.

Build

This project targets the JVM 11+, so be sure to have it available in your environment.

This project relies on the Gradle build system.

If you are on Windows then open a command line, go into the root directory and run:

.\gradlew build

If you are on linux/mac then open a terminal, go into the root directory and run:

./gradlew build

This command line produces a native executable: kafka-processor-cosmos-tx-proto2json-X.Y-runner