Loom implemantation of Dispatcher and Receiver are located in dispatcher-loom and receiver-loom directories respectively.
In these implementations we use Project Loom's virtual threads for the underlyig Kafka communication asynchronously.
Note: This is still in early access and is not yet production ready. It might replace the current implementation in the future. but that will not effect the API or the functionality of the broker.
Pre-requisites: You have followed the CONTRIBUTING & DEVELOPMENT guides and have a Kubernetes cluster up and running and reachable.
To install you can run the following command:
./hack/run.sh deploy-loomOR
Export the environment variable USE_LOOM=true
export USE_LOOM=trueAnd run any command that is available in the run.sh script or any other command that you want to run.