How to Run

1. Start Docker Compose services:

   docker compose up influx_db pulsar01

   Ensure they are healthy.

2. Create directories for zookeeper and bookeeper to store data

   chmod +x create_dirs.sh
   ./create_dirs.sh

3. Set up the producer application:

   cd producer_app
   python3 -m venv venv
   source venv/bin/activate
   pip install -r requirements.txt

4. Start the producer:

   python producer.py

5. Start the consumer:

   python consumer.py

6. Update the token in the consumer if needed:

   • Access InfluxDB admin panel: InfluxDB Admin Panel (username: admin, password: admin123)
   • Access Grafana: Grafana (username: admin, password: admin)

Important Commands

1. docker exec -it pulsar01 bin/pulsar-admin brokers list standalone
2. docker logs pulsar01 --tail 50 -f
3. docker exec -it broker /bin/sh
4. docker compose logs -f