Kafka Processor CØSMOS-Block
A Kafka Streams Processor to unwrap CØSMOS blocks into CØSMOS transactions.
Purpose
The Kafka Processor CØSMOS-Block is basically a Stream Processor which continuously reads CØSMOS blocks from an input Kafka topic, unwraps the CØSMOS transactions and sends them to an output topic.
This processor plays well with the CØSMOS Kafka Connector which provides Kafka with CØSMOS blocks ready to be processed.
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,
- 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 2 JAR files:
- a regular JAR:
kafka-processor-cosmos-block-X.Y.jar - a fat JAR:
kafka-processor-cosmos-block-X.Y-standalone.jar
This last one is the one to use as it contains all the dependencies in it.
34 Dec 30, 2022
0 Dec 9, 2021
11 Jun 10, 2022
3 May 4, 2022
6 Aug 2, 2022
2 May 25, 2022
1 Dec 1, 2021
0 Oct 19, 2021
2 Dec 7, 2021
14 Nov 8, 2022
24 Oct 17, 2022
5 Sep 19, 2022
236 Nov 30, 2022
17 Nov 17, 2022
9 Dec 26, 2022
1 Oct 15, 2021
1 Jun 29, 2022
7 Sep 1, 2022
2 Dec 15, 2021