Run

1. Create a docker network

   docker network create kafka-connection

2. Start Kafka infrastructure

   cd kafka
   docker compose up -d

3. Start producer/consumer/database

   cd consumer
   docker compose up --build -d

4. Check databse

   # in host shell
   docker exec -it postgres bash

   # in container shell
   # to run postgres
   psql -U postgres

   # in postgres cli
   # use database kafka
   \c kafka
   # show tables
   \d
   # look at content of topics
   SELECT * FROM data;
   
   # look at headers
   SELECT * FROM headers;