KaKafka (Kinda Almost Kafka)

Use the following:

• java 17
• maven wrapper with maven 3.9.3 mvn wrapper:wrapper -Dmaven=3.9.3
• Netty 4.x

Build

./mvnw clean package -DskipTests

Local run

After the build is completed you can start a single broker or set of broker using script:

./run.sh

Inside run.sh script you can find cluster configuration:

cluster_mode=true # run application in cluster mode
NODES_CNT=5 # number of broker to start

You can find all running brokers by executing:

jps | grep kakafka-*

To stop all running brokers execute:

./stop-all.sh

Unit/Integration tests.

To execute unit tests just run

./mvnw test

To run integration tests, you should build application first and then run brokers locally using run.sh script.

To execute integration tests just run:

./mvnw verify -Dinteg

Kakafka Protocol Description

//todo: