kafka-streams-stateful

Deploy kafka cluster

docker compose up -d

Setup kafka

docker compose exec -it cli /setup.sh app

If you need to change the quotas config:

docker compose exec -it cli /setup.sh quotas <allowed_rate> <numer_of_stream_threads>

For example:

docker compose exec -it cli /setup.sh quotas 45825 5

Don't forget to restart your kafka brokers:

docker compose restart

Run instances

./run.sh app1

Run data generator

./gradlew -PmainClass=kafka.streams.internals.FakeDataGenerator run

Monitor kafka topics:

kaskade admin -b localhost:19092