A mini app in Node.js utilizing KafkaJS.
- Coming Soon: Replicating Topics to tables in PostgreSQL via Postgres.js (or maybe a different library?)
$ cd app
$ nvm use # if this fails, run `nvm install`
$ corepack enable
$ yarn install
$ cd ..
$ docker compose build all --no-cache$ docker compose up all-kafka -d
# ^ check the logs in the containers to make sure that zookeeper, the brokers, the REST proxy, and the schema registry all started correctly
# TODO: still need to figure out how to add `healthcheck` and startup/retry conditions
# so that **all** of the containers will start up in the correct dependency order
$ docker dompose up mini-app -d
# ^ check the logs in its container to make sure that the topic schema(s) get registeredThen run these in different tabs/windows:
Tab 1
$ docker compose up consumers -d && docker compose logs consumers --followTab 2
$ docker compose up producers -d && docker compose logs producers --follow🚧 WIP 🚧