Normalizer is a stream processing engine based of Kafka Streams. Normalizer does maps (staless and stafull), flatmaps and filters by us. You only need to define a JSON stream where you specify the process logic and how the message are transformed.
Normalizer offers us: scalability, fault tolerance, back-preassure, KV states (RocksDB) and full Kafka integration ... Try it now!!
You can find the docs on the Docs Website
You can get started with Normalizer with this tutorial.
To build this project you can use maven tool.
If you want to build the JAR of the project you can do:
mvn clean package
If you want to check if it passes all the test:
mvn test
If you want to build the distribution tar.gz:
mvn clean package -P dist
If you want to build the docker image, make sure that you have the docker service running:
mvn clean package -P docker
- Fork it
- Create your feature branch:
git checkout -b my-new-feature - Commit your changes:
git commit -am 'Add some feature' - Push to the branch:
git push origin my-new-feature - Create a new Pull Request