Kafka Processor Decode Cosmos TX

Purpose

A Kafka Streams Processor that consumes CØSMOS and ØKP4 Protobuf messages from an input Kafka topic and sends a JSON decoded message in the output topic.

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

You want to get involved? 😍

Please check out OKP4 health files :

• Contributing
• Code of conduct