Skip to content

Latest commit

 

History

History
63 lines (43 loc) · 3.32 KB

File metadata and controls

63 lines (43 loc) · 3.32 KB

Kafka Processor Decode Cosmos TX

version lint build test conventional commits contributor covenant License Quarkus

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 :